Searched refs:next_conn (Results 1 – 3 of 3) sorted by relevance
| /webrtc/webrtc/src/mux/ |
| H A D | mod.rs | 33 next_conn: Arc<dyn Conn + Send + Sync>, field
44 next_conn: Arc::clone(&config.conn), in new()
51 let next_conn = Arc::clone(&m.next_conn); in new() localVariable
54 Mux::read_loop(buffer_size, next_conn, closed_ch_rx, endpoints).await; in new()
72 next_conn: Arc::clone(&self.next_conn), in new_endpoint()
97 next_conn: Arc<dyn Conn + Send + Sync>, in read_loop()
106 result = next_conn.recv(&mut buf) => { in read_loop()
|
| H A D | endpoint.rs | 16 pub(crate) next_conn: Arc<dyn Conn + Send + Sync>, field
54 self.next_conn.send(buf).await in send()
62 self.next_conn.local_addr() in local_addr()
66 self.next_conn.remote_addr() in remote_addr()
70 self.next_conn.close().await in close()
|
| /webrtc/dtls/src/conn/ |
| H A D | mod.rs | 524 next_conn: &Arc<dyn util::Conn + Send + Sync>, in handle_outgoing_packets()
584 next_conn.send(compacted_raw_packets).await?; in handle_outgoing_packets()
748 next_conn: &Arc<dyn util::Conn + Send + Sync>, in read_and_buffer()
754 let n = next_conn.recv(buf).await?; in read_and_buffer()
|