Searched refs:state_watch_rx (Results 1 – 1 of 1) sorted by relevance
165 let mut state_watch_rx = self.state_tx.subscribe(); in read() localVariable168 State::wait_for(&mut state_watch_rx, &[State::Started, State::Paused]).await?; in read()176 res = State::error_on_close(&mut state_watch_rx) => { in read()194 let mut state_watch_rx = self.state_tx.subscribe(); in read_simulcast() localVariable198 State::wait_for(&mut state_watch_rx, &[State::Started, State::Paused]).await?; in read_simulcast()208 res = State::error_on_close(&mut state_watch_rx) => { in read_simulcast()255 let mut state_watch_rx = self.state_tx.subscribe(); in read_rtp() localVariable258 State::wait_for(&mut state_watch_rx, &[State::Started]).await?; in read_rtp()285 let mut current_state = *state_watch_rx.borrow(); in read_rtp()288 _ = state_watch_rx.changed() => { in read_rtp()[all …]