pub(crate) async fn crank_all(&mut self, rng: &mut TestRng) -> usize {
        let mut event_count = 0;
        for node in self.nodes.values_mut() {
            let node_id = node.reactor().node_id();
            event_count += if node
                .try_crank(rng)
                .instrument(error_span!("crank", node_id = %node_id))
                .await
                .is_some()
            {
                1
            } else {
                0
            }
        }

        event_count
    }
/// Crank all runners once, returning the number of events processed.
Crank all runners once, returning the number of events processed.
Crank all runners once returning the number of events processed .
pub(crate) async fn crank_all(&mut self, rng: &mut TestRng) -> usize {
        let mut event_count = 0;
        for node in self.nodes.values_mut() {
            let node_id = node.reactor().node_id();
            event_count += if node
                .try_crank(rng)
                .instrument(error_span!("crank", node_id = %node_id))
                .await
                .is_some()
            {
                1
            } else {
                0
            }
        }
        event_count
    }
pub ( crate ) async fn crank_all ( & mut self , rng : & mut TestRng ) -> usize { let mut event_count = 0 ; for node in self . nodes . values_mut ( ) { let node_id = node . reactor ( ) . node_id ( ) ; event_count += if node . try_crank ( rng ) . instrument ( error_span ! ( " " node_id node_id ) ) . await . is_some ( ) { 1 } else { 0 } } event_count }
Crank all runners once, returning the number of events processed.
Crank all runners once returning the number of events processed .
&mut self
rng
&mut TestRng
&mut self
rng
&mut TestRng