Skip to main content

wait_ready

Function wait_ready 

Source
pub fn wait_ready(
    rx: &Receiver<WatchEvent>,
    patience: Duration,
) -> (Readiness, Vec<Vec<String>>)
Expand description

Wait up to patience for the stream’s Ready. Any Batch that arrives first is returned alongside, in order, so nothing the adapter reported before readiness is lost to the caller.