Searched refs:rx (Results 1 – 9 of 9) sorted by relevance
| /webrtc/util/src/conn/ |
| H A D | conn_bridge_test.rs | 19 let (tx, mut rx) = mpsc::channel(1); in test_bridge_normal()
30 let n = rx.recv().await.unwrap(); in test_bridge_normal()
45 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn0()
57 let n = rx.recv().await.unwrap(); in test_bridge_drop_1st_packet_from_conn0()
72 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_2nd_packet_from_conn0()
84 let n = rx.recv().await.unwrap(); in test_bridge_drop_2nd_packet_from_conn0()
99 let (tx, mut rx) = mpsc::channel(1); in test_bridge_drop_1st_packet_from_conn1()
111 let n = rx.recv().await.unwrap(); in test_bridge_drop_1st_packet_from_conn1()
138 let n = rx.recv().await.unwrap(); in test_bridge_drop_2nd_packet_from_conn1()
162 let _ = rx.recv().await; in test_bridge_reorder_packets_from_conn0()
[all …]
|
| /webrtc/ice/examples/ |
| H A D | ping_pong.rs | 30 let (tx, rx) = mpsc::channel::<String>(3);
31 (Arc::new(Mutex::new(tx)), Arc::new(Mutex::new(rx)))
35 let (tx, rx) = mpsc::channel::<String>(10);
36 (Arc::new(Mutex::new(tx)), Arc::new(Mutex::new(rx)))
266 let mut rx = REMOTE_AUTH_CHANNEL.1.lock().await; in main() localVariable
267 if let Some(s) = rx.recv().await { in main()
280 let mut rx = REMOTE_CAND_CHANNEL.1.lock().await; in main() localVariable
287 result = rx.recv() => { in main()
|
| /webrtc/interceptor/src/stats/ |
| H A D | interceptor.rs | 99 let (tx, rx) = mpsc::channel(100); in new()
101 tokio::spawn(run_stats_reducer(rx)); in new()
116 let (tx, rx) = mpsc::channel(100); in with_time_gen()
117 tokio::spawn(run_stats_reducer(rx)); in with_time_gen()
132 let (tx, rx) = oneshot::channel(); in fetch_inbound_stats()
147 rx.await.unwrap_or_default() in fetch_inbound_stats()
154 let (tx, rx) = oneshot::channel(); in fetch_outbound_stats()
169 rx.await.unwrap_or_default() in fetch_outbound_stats()
173 async fn run_stats_reducer(mut rx: mpsc::Receiver<Message>) { in run_stats_reducer()
179 maybe_msg = rx.recv() => { in run_stats_reducer()
|
| /webrtc/stun/src/ |
| H A D | agent.rs | 265 pub(crate) async fn run(mut agent: Agent, mut rx: mpsc::Receiver<ClientAgent>) { in run()
266 while let Some(client_agent) = rx.recv().await { in run()
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_receiver/ |
| H A D | mod.rs | 110 async fn wait_for(rx: &mut watch::Receiver<State>, states: &[State]) -> Result<()> { in wait_for()
112 let state = *rx.borrow(); in wait_for()
122 if rx.changed().await.is_err() { in wait_for()
128 async fn error_on_close(rx: &mut watch::Receiver<State>) -> Result<()> { in error_on_close()
129 if rx.changed().await.is_err() { in error_on_close()
133 let state = *rx.borrow(); in error_on_close()
|
| /webrtc/webrtc/src/rtp_transceiver/ |
| H A D | srtp_writer_future.rs | 131 let mut rx = self.rtp_transport.srtp_ready_rx.lock().await; in init() localVariable
132 if let Some(srtp_ready_rx) = &mut *rx { in init()
|
| /webrtc/turn/src/client/ |
| H A D | transaction.rs | 146 let (tx, rx) = mpsc::channel(1); in new()
147 (Some(tx), Some(rx)) in new()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 296 let rx = packet_rx.recv().await; in new() localVariable
297 if let Some(r) = rx { in new()
395 let rx = { in read() localVariable
410 if let Some(out) = rx { in read()
512 let (tx, mut rx) = mpsc::channel(1); in write_packets()
516 if let Some(result) = rx.recv().await { in write_packets()
|
| /webrtc/turn/src/allocation/allocation_manager/ |
| H A D | allocation_manager_test.rs | 570 let (tx, mut rx) = mpsc::channel::<AllocationInfo>(1); in test_alloc_close_notify()
573 if let Some(alloc) = rx.recv().await { in test_alloc_close_notify()
|