pub(crate) async fn crank(&mut self, node_id: &R::NodeId, rng: &mut TestRng) -> usize {
        let runner = self.nodes.get_mut(node_id).expect("should find node");

        let node_id = runner.reactor().node_id();
        if runner
            .try_crank(rng)
            .instrument(error_span!("crank", node_id = %node_id))
            .await
            .is_some()
        {
            1
        } else {
            0
        }
    }
/// Crank the specified runner once, returning the number of events processed.
Crank the specified runner once, returning the number of events processed.
Crank the specified runner once returning the number of events processed .
pub(crate) async fn crank(&mut self, node_id: &R::NodeId, rng: &mut TestRng) -> usize {
        let runner = self.nodes.get_mut(node_id).expect("should find node");
        let node_id = runner.reactor().node_id();
        if runner
            .try_crank(rng)
            .instrument(error_span!("crank", node_id = %node_id))
            .await
            .is_some()
        {
            1
        } else {
            0
        }
    }
pub ( crate ) async fn crank ( & mut self , node_id : & R :: NodeId , rng : & mut TestRng ) -> usize { let runner = self . nodes . get_mut ( node_id ) . expect ( " " ) ; let node_id = runner . reactor ( ) . node_id ( ) ; if runner . try_crank ( rng ) . instrument ( error_span ! ( " " node_id node_id ) ) . await . is_some ( ) { 1 } else { 0 } }
Crank the specified runner once, returning the number of events processed.
Crank the specified runner once returning the number of events processed .
&mut self
node_id
&R::NodeId
rng
&mut TestRng
&mut self
node_id
&R::NodeId
rng
&mut TestRng