Searched refs:wr_tx (Results 1 – 3 of 3) sorted by relevance
9 wr_tx: Mutex<mpsc::Sender<Vec<u8>>>, field18 wr_tx: Mutex::new(cb2_tx), in pipe()23 wr_tx: Mutex::new(cb1_tx), in pipe()52 let wr_tx = self.wr_tx.lock().await; in send() localVariable53 match wr_tx.send(b.to_vec()).await { in send()
80 wr_tx: [Option<mpsc::Sender<Bytes>>; 2], field94 wr_tx: [Some(wr_tx0), Some(wr_tx1)], in new()196 if let Some(wr_tx) = &self.wr_tx[1 - id] { in tick()197 let _ = wr_tx.send(d).await; in tick()
2103 wr_tx: Mutex<mpsc::Sender<Vec<u8>>>, field2117 let (wr_tx, rd_rx) = mpsc::channel(1); in default()2119 wr_tx: Mutex::new(wr_tx), in default()2164 let wr_tx = self.wr_tx.lock().await; in send() localVariable2165 match wr_tx.send(b.to_vec()).await { in send()