pub fn new() -> Self {
        let (tx, rx) = unbounded();

        tokio::spawn(async {
            waiter(rx).await;
        });

        Self(tx)
    }
/// Creates a new local queue.
Creates a new local queue.
Creates a new local queue .
pub fn new() -> Self {
        let (tx, rx) = unbounded();
        tokio::spawn(async {
            waiter(rx).await;
        });
        Self(tx)
    }
pub fn new ( ) -> Self { let ( tx , rx ) = unbounded ( ) ; tokio :: spawn ( async { waiter ( rx ) . await ; } ) ; Self ( tx ) }
Creates a new local queue.
Creates a new local queue .