// Waits for the flows/connections to be up
Waits for the flows/connections to be up
Waits for the flows / connections to be up
async fn wait_for_flow_up(&self) -> Result<(), TestClientErrorCode> {
        let expected_flows = 4;
        for _ in 0..10 {
            let num_flows = self.active_flows.lock().unwrap().len();
            if num_flows == expected_flows {
                info!(self.log, "Expected flows up: {}", expected_flows);
                return Ok(());
            }
            info!(
                self.log,
                "Flows up: {}/{}, to wait ...", num_flows, expected_flows
            );
            tokio::time::sleep(Duration::from_secs(3)).await;
        }
        warn!(self.log, "All flows not up, exiting");
        Err(TestClientErrorCode::NotAllFlowsUp)
    }
async fn wait_for_flow_up ( & self ) -> Result < ( ) , TestClientErrorCode > { let expected_flows = 4 ; for _ in 0 .. 10 { let num_flows = self . active_flows . lock ( ) . unwrap ( ) . len ( ) ; if num_flows == expected_flows { info ! ( self log " " expected_flows ) ; return Ok ( ( ) ) ; } info ! ( self log " " num_flows expected_flows ) ; tokio :: time :: sleep ( Duration :: from_secs ( 3 ) ) . await ; } warn ! ( self log " " ) ; Err ( TestClientErrorCode :: NotAllFlowsUp ) }
Waits for the flows/connections to be up
Waits for the flows / connections to be up
&self