fn wait_for_flow_up(&self) {
        let expected_flows = 1;
        loop {
            let num_flows = self.active_flows.lock().unwrap().len();
            if num_flows == expected_flows {
                info!(self.log, "All expected {} flows up", expected_flows);
                return;
            }
            info!(
                self.log,
                "Flows up: {} out of {}, to wait ...", num_flows, expected_flows
            );
            thread::sleep(Duration::from_secs(3));
        }
    }
// Waits for the flows/connections to be up
Waits for the flows/connections to be up
Waits for the flows / connections to be up
fn wait_for_flow_up(&self) {
        let expected_flows = 1;
        loop {
            let num_flows = self.active_flows.lock().unwrap().len();
            if num_flows == expected_flows {
                info!(self.log, "All expected {} flows up", expected_flows);
                return;
            }
            info!(
                self.log,
                "Flows up: {} out of {}, to wait ...", num_flows, expected_flows
            );
            thread::sleep(Duration::from_secs(3));
        }
    }
fn wait_for_flow_up ( & self ) { let expected_flows = 1 ; loop { let num_flows = self . active_flows . lock ( ) . unwrap ( ) . len ( ) ; if num_flows == expected_flows { info ! ( self log " " expected_flows ) ; return ; } info ! ( self log " " num_flows expected_flows ) ; thread :: sleep ( Duration :: from_secs ( 3 ) ) ; } }
Waits for the flows/connections to be up
Waits for the flows / connections to be up
&self
&self