Searched refs:on_connected_rx (Results 1 – 2 of 2) sorted by relevance
22 let (on_connected_rx, agent_conn) = { in dial()27 let mut on_connected_rx = self.internal.on_connected_rx.lock().await; in dial() localVariable29 on_connected_rx.take(), in dial()34 if let Some(mut on_connected_rx) = on_connected_rx { in dial()37 _ = on_connected_rx.recv() => {}, in dial()57 let (on_connected_rx, agent_conn) = { in accept()62 let mut on_connected_rx = self.internal.on_connected_rx.lock().await; in accept() localVariable64 on_connected_rx.take(), in accept()69 if let Some(mut on_connected_rx) = on_connected_rx { in accept()72 _ = on_connected_rx.recv() => {}, in accept()
24 pub(crate) on_connected_rx: Mutex<Option<mpsc::Receiver<()>>>, field89 let (on_connected_tx, on_connected_rx) = mpsc::channel(1); in new()96 on_connected_rx: Mutex::new(Some(on_connected_rx)), in new()