| /webrtc/interceptor/src/report/ |
| H A D | mod.rs | 39 let (close_tx, close_rx) = mpsc::channel(1); in build_rr()
49 close_rx: Mutex::new(Some(close_rx)), in build_rr()
58 let (close_tx, close_rx) = mpsc::channel(1); in build_sr()
68 close_rx: Mutex::new(Some(close_rx)), in build_sr()
|
| /webrtc/interceptor/src/twcc/receiver/ |
| H A D | mod.rs | 33 let (close_tx, close_rx) = mpsc::channel(1); in build()
45 close_rx: Mutex::new(Some(close_rx)), in build()
67 close_rx: Mutex<Option<mpsc::Receiver<()>>>, field
98 let mut close_rx = { in run() localVariable
99 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
100 if let Some(close_rx) = close_rx.take() { in run()
101 close_rx in run()
120 _ = close_rx.recv() =>{ in run()
|
| /webrtc/interceptor/src/nack/generator/ |
| H A D | mod.rs | 56 let (close_tx, close_rx) = mpsc::channel(1); in build()
76 close_rx: Mutex::new(Some(close_rx)), in build()
91 close_rx: Mutex<Option<mpsc::Receiver<()>>>, field
118 let mut close_rx = { in run() localVariable
119 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
120 if let Some(close) = close_rx.take() { in run()
156 _ = close_rx.recv() =>{ in run()
|
| /webrtc/interceptor/src/report/sender/ |
| H A D | mod.rs | 19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>, field
49 let mut close_rx = { in run() localVariable
50 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
51 if let Some(close) = close_rx.take() { in run()
80 _ = close_rx.recv() =>{ in run()
|
| /webrtc/interceptor/src/report/receiver/ |
| H A D | mod.rs | 19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>, field
87 let mut close_rx = { in run() localVariable
88 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
89 if let Some(close) = close_rx.take() { in run()
119 _ = close_rx.recv() =>{ in run()
|
| /webrtc/webrtc/src/peer_connection/operation/ |
| H A D | mod.rs | 50 let (close_tx, close_rx) = mpsc::channel(1); in new()
55 Operations::start(l, ops_tx, ops_rx, close_rx).await; in new()
112 mut close_rx: mpsc::Receiver<()>, in start()
116 _ = close_rx.recv() => { in start()
|
| /webrtc/sctp/src/timer/ |
| H A D | rtx_timer.rs | 138 let mut close_rx = { in start() localVariable
144 let (close_tx, close_rx) = mpsc::channel(1); in start()
146 close_rx in start()
186 _ = close_rx.recv() => break, in start()
|
| H A D | ack_timer.rs | 39 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
54 _ = close_rx.recv() => {}, in start()
|
| /webrtc/turn/src/client/ |
| H A D | periodic_timer.rs | 55 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
69 _ = close_rx.recv() => break, in start()
|
| /webrtc/stun/src/ |
| H A D | client.rs | 46 let (close_tx, mut close_rx) = mpsc::channel(1); in start()
54 _ = close_rx.recv() => break, in start()
222 mut close_rx: mpsc::Receiver<()>, in read_until_closed()
231 _ = close_rx.recv() => return, in read_until_closed()
386 let (close_tx, close_rx) = mpsc::channel(1); in run()
423 async move { Client::read_until_closed(close_rx, conn_rx, client_agent_tx).await }, in run()
|
| /webrtc/ice/src/udp_mux/ |
| H A D | mod.rs | 271 let mut close_rx = muxed_conn.close_rx(); in get_conn() localVariable
275 let _ = close_rx.changed().await; in get_conn()
|
| H A D | udp_mux_conn.rs | 105 pub fn close_rx(&self) -> watch::Receiver<bool> { in close_rx() method
|
| /webrtc/turn/src/server/ |
| H A D | mod.rs | 154 let (mut close_tx, mut close_rx) = oneshot::channel::<()>(); in read_loop()
175 close_rx.close(); in read_loop()
|