pub async fn wait_for_integration<Db: ReadAccess<DbKindDht>>(
    db: &Db,
    expected_count: usize,
    num_attempts: usize,
    delay: Duration
)
Expand description

Exit early if the expected number of ops have been integrated or wait for num_attempts * delay