Searched refs:send_called_rx (Results 1 – 1 of 1) sorted by relevance
29 pub(crate) send_called_rx: Mutex<mpsc::Receiver<()>>, field38 let mut send_called_rx = self.send_called_rx.lock().await; in read() localVariable41 _ = send_called_rx.recv() =>{ in read()144 let (send_called_tx, send_called_rx) = mpsc::channel(1); in new()151 send_called_rx: Mutex::new(send_called_rx), in new()