Searched refs:read_ch_rx (Results 1 – 4 of 4) sorted by relevance
| /webrtc/util/src/vnet/ |
| H A D | conn.rs | 34 read_ch_rx: Mutex<mpsc::Receiver<Box<dyn Chunk + Send + Sync>>>, field
45 let (read_ch_tx, read_ch_rx) = mpsc::channel(MAX_READ_QUEUE_SIZE); in new()
51 read_ch_rx: Mutex::new(read_ch_rx), in new()
82 let mut read_ch = self.read_ch_rx.lock().await; in recv_from()
|
| /webrtc/turn/src/client/relay_conn/ |
| H A D | relay_conn_test.rs | 48 let (_read_ch_tx, read_ch_rx) = mpsc::channel(100); in test_relay_conn()
56 read_ch_rx: Arc::new(Mutex::new(read_ch_rx)), in test_relay_conn()
|
| /webrtc/turn/src/client/ |
| H A D | relay_conn.rs | 60 pub(crate) read_ch_rx: Arc<Mutex<mpsc::Receiver<InboundData>>>, field
76 read_ch_rx: Arc<Mutex<mpsc::Receiver<InboundData>>>, field
91 read_ch_rx: Arc::clone(&config.read_ch_rx), in new()
130 let mut read_ch_rx = self.read_ch_rx.lock().await; in recv_from() localVariable
132 if let Some(ib_data) = read_ch_rx.recv().await { in recv_from()
|
| H A D | mod.rs | 558 let (read_ch_tx, read_ch_rx) = mpsc::channel(MAX_READ_QUEUE_SIZE); in allocate()
571 read_ch_rx: Arc::new(Mutex::new(read_ch_rx)), in allocate()
|