Searched refs:close_loop_ch_rx (Results 1 – 2 of 2) sorted by relevance
206 close_loop_ch_rx: Mutex<broadcast::Receiver<()>>, field268 let mut close_loop_ch_rx = self.close_loop_ch_rx.lock().await; in shutdown() localVariable269 let _ = close_loop_ch_rx.recv().await; in shutdown()291 let (close_loop_ch_tx, close_loop_ch_rx) = broadcast::channel(1); in new()412 close_loop_ch_rx: Mutex::new(close_loop_ch_rx), in new()
2339 let mut close_loop_ch_rx = a2.close_loop_ch_rx.lock().await; in test_association_shutdown() localVariable2348 _ = close_loop_ch_rx.recv() => { in test_association_shutdown()2411 let mut close_loop_ch_rx = a1.close_loop_ch_rx.lock().await; in test_association_shutdown_during_write() localVariable2422 let result = close_loop_ch_rx.recv().await; in test_association_shutdown_during_write()2429 let mut close_loop_ch_rx = a2.close_loop_ch_rx.lock().await; in test_association_shutdown_during_write() localVariable2437 _ = close_loop_ch_rx.recv() => { in test_association_shutdown_during_write()