async fn request(&self) {
        let (tx, rx) = oneshot::channel();

        if let Err(err) = self.0.clone().send(tx).await {
            warn!("[LocalQueue] send failed with: {:?}, skipping", err);
            return;
        }

        warn!("Waiting for allowance!");

        let _ = rx.await;
    }
/// Request to be able to identify with the gateway. This will place this
/// request behind all other requests, and the returned future will resolve
/// once the request has been completed.
Request to be able to identify with the gateway. This will place this
request behind all other requests, and the returned future will resolve
once the request has been completed.
Request to be able to identify with the gateway . This will place this request behind all other requests and the returned future will resolve once the request has been completed .
async fn request(&self) {
        let (tx, rx) = oneshot::channel();
        if let Err(err) = self.0.clone().send(tx).await {
            warn!("[LocalQueue] send failed with: {:?}, skipping", err);
            return;
        }
        warn!("Waiting for allowance!");
        let _ = rx.await;
    }
async fn request ( & self ) { let ( tx , rx ) = oneshot :: channel ( ) ; if let Err ( err ) = self . 0 . clone ( ) . send ( tx ) . await { warn ! ( " " err ) ; return ; } warn ! ( " " ) ; let _ = rx . await ; }
Request to be able to identify with the gateway.
Request to be able to identify with the gateway .
&self
&self