Searched defs:close_rx (Results 1 – 7 of 7) sorted by relevance
19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>, field49 let mut close_rx = { in run() localVariable50 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
19 pub(crate) close_rx: Mutex<Option<mpsc::Receiver<()>>>, field87 let mut close_rx = { in run() localVariable88 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
91 close_rx: Mutex<Option<mpsc::Receiver<()>>>, field118 let mut close_rx = { in run() localVariable119 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
67 close_rx: Mutex<Option<mpsc::Receiver<()>>>, field98 let mut close_rx = { in run() localVariable99 let mut close_rx = internal.close_rx.lock().await; in run() localVariable
138 let mut close_rx = { in start() localVariable
271 let mut close_rx = muxed_conn.close_rx(); in get_conn() localVariable
105 pub fn close_rx(&self) -> watch::Receiver<bool> { in close_rx() method