Searched refs:rd_rx (Results 1 – 3 of 3) sorted by relevance
8 rd_rx: Mutex<mpsc::Receiver<Vec<u8>>>, field17 rd_rx: Mutex::new(cb1_rx), in pipe()22 rd_rx: Mutex::new(cb2_rx), in pipe()36 let mut rd_rx = self.rd_rx.lock().await; in recv() localVariable37 let v = match rd_rx.recv().await { in recv()
18 rd_rx: Mutex<mpsc::Receiver<Bytes>>, field29 let mut rd_rx = self.rd_rx.lock().await; in recv() localVariable30 let v = match rd_rx.recv().await { in recv()101 rd_rx: Mutex::new(rd_rx0), in new()107 rd_rx: Mutex::new(rd_rx1), in new()
2104 rd_rx: Mutex<mpsc::Receiver<Vec<u8>>>, field2117 let (wr_tx, rd_rx) = mpsc::channel(1); in default()2120 rd_rx: Mutex::new(rd_rx), in default()2146 let mut rd_rx = self.rd_rx.lock().await; in recv() localVariable2147 let v = match rd_rx.recv().await { in recv()