Searched refs:started_ch_tx (Results 1 – 1 of 1) sorted by relevance
51 pub(crate) started_ch_tx: Mutex<Option<broadcast::Sender<()>>>, field92 let (started_ch_tx, _) = broadcast::channel(1); in new()124 started_ch_tx: Mutex::new(Some(started_ch_tx)), in new()174 let started_ch_tx = self.started_ch_tx.lock().await; in start_connectivity_checks() localVariable175 if started_ch_tx.is_none() { in start_connectivity_checks()191 let mut started_ch_tx = self.started_ch_tx.lock().await; in start_connectivity_checks() localVariable192 started_ch_tx.take(); in start_connectivity_checks()558 let started_ch_tx = self.started_ch_tx.lock().await; in add_candidate() localVariable559 (*started_ch_tx).as_ref().map(|tx| tx.subscribe()) in add_candidate()623 let mut started_ch_tx = self.started_ch_tx.lock().await; in close() localVariable[all …]