pub async fn consistency_envs(all_cell_envs: &[&EnvWrite], num_attempts: usize, delay: Duration) {
    let mut expected_count = 0;
    for &env in all_cell_envs.iter() {
        let count = get_published_ops(env).len();
        expected_count += count;
    }
    for &env in all_cell_envs.iter() {
        wait_for_integration(env, expected_count, num_attempts, delay).await
    }
}
/// Wait for all cell envs to reach consistency
Wait for all cell envs to reach consistency
Wait for all cell envs to reach consistency
pub async fn consistency_envs(all_cell_envs: &[&EnvWrite], num_attempts: usize, delay: Duration) {
    let mut expected_count = 0;
    for &env in all_cell_envs.iter() {
        let count = get_published_ops(env).len();
        expected_count += count;
    }
    for &env in all_cell_envs.iter() {
        wait_for_integration(env, expected_count, num_attempts, delay).await
    }
}
pub async fn consistency_envs ( all_cell_envs : & [ & EnvWrite ] , num_attempts : usize , delay : Duration ) { let mut expected_count = 0 ; for & env in all_cell_envs . iter ( ) { let count = get_published_ops ( env ) . len ( ) ; expected_count += count ; } for & env in all_cell_envs . iter ( ) { wait_for_integration ( env , expected_count , num_attempts , delay ) . await } }
Wait for all cell envs to reach consistency
Wait for all cell envs to reach consistency
all_cell_envs
&[&EnvWrite]
num_attempts
usize
delay
Duration
all_cell_envs
&[&EnvWrite]
num_attempts
usize
delay
Duration