Searched defs:read_ch_tx (Results 1 – 4 of 4) sorted by relevance
9 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<Box<dyn Chunk + Send + Sync>>>>>, field18 let read_ch_tx = self.read_ch_tx.lock().await; in write() localVariable
73 read_ch_tx: Arc<Mutex<Option<mpsc::Sender<InboundData>>>>, field221 let read_ch_tx = Arc::clone(&self.read_ch_tx); in listen() localVariable427 let mut read_ch_tx = self.read_ch_tx.lock().await; in close() localVariable486 let read_ch_tx = self.read_ch_tx.lock().await; in allocate() localVariable
56 let read_ch_tx = conn.get_inbound_ch(); in write() localVariable164 let read_ch_tx = conn.get_inbound_ch(); in on_inbound_chunk() localVariable
33 read_ch_tx: Arc<Mutex<Option<ChunkChTx>>>, field