pub fn run_until<R>( rt: &R, timeout: Duration, predicate: impl FnMut() -> bool, ) -> boolwhere R: TestDrain,