Searched refs:wait_for (Results 1 – 1 of 1) sorted by relevance
110 async fn wait_for(rx: &mut watch::Receiver<State>, states: &[State]) -> Result<()> { in wait_for() method168 State::wait_for(&mut state_watch_rx, &[State::Started, State::Paused]).await?; in read()198 State::wait_for(&mut state_watch_rx, &[State::Started, State::Paused]).await?; in read_simulcast()258 State::wait_for(&mut state_watch_rx, &[State::Started]).await?; in read_rtp()