Searched refs:stop_called_rx (Results 1 – 2 of 2) sorted by relevance
30 pub(crate) stop_called_rx: Arc<Notify>, field49 _ = self.stop_called_rx.notified() => { in read()60 _ = self.stop_called_rx.notified() =>{ in read()146 let stop_called_rx = stop_called_tx.clone(); in new() localVariable152 stop_called_rx, in new()
135 _ = rtp_sender.stop_called_rx.notified()=> return Err(Error::ErrClosedPipe), in init()