pub fn wait_network_ready(&self) -> impl Future<Output = Result<()>> {
        let (send, recv) = oneshot::channel();
        let sender = self.send_messages.clone();
        async move {
            sender.send(NetworkManagerMessage::WaitNetworkReady(send)).await
                .map_err(|_| NetworkError::NotActive)?;
            let result = recv.await
                .map_err(|_| NetworkError::NotActive)?;
            result
        }
    }
/// The main async future of NetworkManager.
///
/// Finishes once routes have been resolved, and SNP is ready to use - after that
/// calling BW functions that use network is fine, messages sent here will be forwarded
/// through rally-point, and received messages will be pushed to snp's queue + handle
/// signaled automatically.
The main async future of NetworkManager.
Finishes once routes have been resolved, and SNP is ready to use - after that
calling BW functions that use network is fine, messages sent here will be forwarded
through rally-point, and received messages will be pushed to snp's queue + handle
signaled automatically.
The main async future of NetworkManager . Finishes once routes have been resolved and SNP is ready to use - after that calling BW functions that use network is fine messages sent here will be forwarded through rally - point and received messages will be pushed to snp ' s queue + handle signaled automatically .
pub fn wait_network_ready(&self) -> impl Future<Output = Result<()>> {
        let (send, recv) = oneshot::channel();
        let sender = self.send_messages.clone();
        async move {
            sender.send(NetworkManagerMessage::WaitNetworkReady(send)).await
                .map_err(|_| NetworkError::NotActive)?;
            let result = recv.await
                .map_err(|_| NetworkError::NotActive)?;
            result
        }
    }
pub fn wait_network_ready ( & self ) -> impl Future < Output = Result < ( ) > > { let ( send , recv ) = oneshot :: channel ( ) ; let sender = self . send_messages . clone ( ) ; async move { sender . send ( NetworkManagerMessage :: WaitNetworkReady ( send ) ) . await . map_err ( | _ | NetworkError :: NotActive ) ? ; let result = recv . await . map_err ( | _ | NetworkError :: NotActive ) ? ; result } }
The main async future of NetworkManager.
The main async future of NetworkManager .
&self
&self