Function wait_for_counts 

pub async fn wait_for_counts(
    pool: &PgPool,
    queue: &str,
    predicate: impl Fn(&HashMap<String, i64>) -> bool,
    timeout: Duration,
) -> HashMap<String, i64>

Poll queue state counts until a predicate is satisfied, or panic on timeout.