pub fn spawn(self) -> JoinHandle<Result<(), DhtConnectivityError>> {
        let connectivity_events = self.connectivity.get_event_subscription();
        task::spawn(async move {
            match self.run(connectivity_events).await {
                Ok(_) => Ok(()),
                Err(err) => {
                    error!(target: LOG_TARGET, "DhtConnectivity exited with error: {:?}", err);
                    Err(err)
                },
            }
        })
    }
/// Spawn a DhtConnectivity actor. This will immediately subscribe to the connection manager event stream to
/// prevent unexpected missed events.
Spawn a DhtConnectivity actor. This will immediately subscribe to the connection manager event stream to
prevent unexpected missed events.
Spawn a DhtConnectivity actor . This will immediately subscribe to the connection manager event stream to prevent unexpected missed events .
pub fn spawn(self) -> JoinHandle<Result<(), DhtConnectivityError>> {
        let connectivity_events = self.connectivity.get_event_subscription();
        task::spawn(async move {
            match self.run(connectivity_events).await {
                Ok(_) => Ok(()),
                Err(err) => {
                    error!(target: LOG_TARGET, "DhtConnectivity exited with error: {:?}", err);
                    Err(err)
                },
            }
        })
    }
pub fn spawn ( self ) -> JoinHandle < Result < ( ) , DhtConnectivityError > > { let connectivity_events = self . connectivity . get_event_subscription ( ) ; task :: spawn ( async move { match self . run ( connectivity_events ) . await { Ok ( _ ) => Ok ( ( ) ) , Err ( err ) => { error ! ( target LOG_TARGET " " err ) ; Err ( err ) } , } } ) }
Spawn a DhtConnectivity actor.
Spawn a DhtConnectivity actor .
self
self