pub async fn wait_for_all_agents_to_be_healthy(&self) {
        println!("Waiting for all replicas to be healthy!");
        for agent in &self.agents {
            while !agent.is_replica_healthy().await {
                tokio::time::sleep(Duration::from_secs(1)).await;
            }
        }
        println!("All replicas are healthy!");
    }
// Goes over all agents and makes sure they are connected and the corresponding
// replicas are healthy.
Goes over all agents and makes sure they are connected and the corresponding
replicas are healthy.
Goes over all agents and makes sure they are connected and the corresponding replicas are healthy .
pub async fn wait_for_all_agents_to_be_healthy(&self) {
        println!("Waiting for all replicas to be healthy!");
        for agent in &self.agents {
            while !agent.is_replica_healthy().await {
                tokio::time::sleep(Duration::from_secs(1)).await;
            }
        }
        println!("All replicas are healthy!");
    }
pub async fn wait_for_all_agents_to_be_healthy ( & self ) { println ! ( " " ) ; for agent in & self . agents { while ! agent . is_replica_healthy ( ) . await { tokio :: time :: sleep ( Duration :: from_secs ( 1 ) ) . await ; } } println ! ( " " ) ; }
Goes over all agents and makes sure they are connected and the corresponding
replicas are healthy.
Goes over all agents and makes sure they are connected and the corresponding replicas are healthy .
&self
&self