Function drain_until 

pub fn drain_until<R>(rt: &R, timeout: Duration) -> usize
where
    R: TestDrain,