pub async fn stop(&self) -> Result<()> {
        println!("Node: shutting down all workers");

        match self.sender.send(NodeMessage::StopNode).await {
            Ok(()) => Ok(()),
            Err(_e) => Err(Error::FailedStopNode.into()),
        }
    }
/// Send messages to all workers to shut them down
Send messages to all workers to shut them down
Send messages to all workers to shut them down
pub async fn stop(&self) -> Result<()> {
        println!("Node: shutting down all workers");
        match self.sender.send(NodeMessage::StopNode).await {
            Ok(()) => Ok(()),
            Err(_e) => Err(Error::FailedStopNode.into()),
        }
    }
pub async fn stop ( & self ) -> Result < ( ) > { println ! ( " " ) ; match self . sender . send ( NodeMessage :: StopNode ) . await { Ok ( ( ) ) => Ok ( ( ) ) , Err ( _e ) => Err ( Error :: FailedStopNode . into ( ) ) , } }
Send messages to all workers to shut them down
Send messages to all workers to shut them down
&self
&self