Searched refs:chan_candidate_tx (Results 1 – 3 of 3) sorted by relevance
33 pub(crate) chan_candidate_tx: ChanCandidateTx, field87 let (chan_candidate_tx, chan_candidate_rx) = mpsc::channel(1); in new()105 chan_candidate_tx: Arc::new(Mutex::new(Some(chan_candidate_tx))), in new()604 let chan_candidate_tx = self.chan_candidate_tx.lock().await; in add_candidate() localVariable605 if let Some(tx) = &*chan_candidate_tx { in add_candidate()632 let mut chan_candidate_tx = self.chan_candidate_tx.lock().await; in close() localVariable633 chan_candidate_tx.take(); in close()
35 pub(crate) chan_candidate_tx: ChanCandidateTx, field81 ¶ms.chan_candidate_tx, in gather_candidates_internal()170 ¶ms.chan_candidate_tx, in gather_candidates_internal()178 chan_candidate_tx: &ChanCandidateTx, in set_gathering_state()185 let cand_tx = chan_candidate_tx.lock().await; in set_gathering_state()
460 chan_candidate_tx: Arc::clone(&self.internal.chan_candidate_tx), in gather_candidates()