Searched refs:closed_ch (Results 1 – 2 of 2) sorted by relevance
53 pub(crate) closed_ch: Arc<Mutex<Option<broadcast::Sender<()>>>>, field83 closed_ch: Arc::new(Mutex::new(None)), in default()243 let mut closed_ch = self.closed_ch.lock().await; in close() localVariable244 if closed_ch.is_none() { in close()247 closed_ch.take(); in close()311 self.closed_ch.clone() in get_closed_ch()
1032 let closed_ch = candidate.get_closed_ch(); in start_candidate() localVariable1033 let mut closed = closed_ch.lock().await; in start_candidate()