Searched refs:closed_ch_tx (Results 1 – 2 of 2) sorted by relevance
36 closed_ch_tx: Option<mpsc::Sender<()>>, field41 let (closed_ch_tx, closed_ch_rx) = mpsc::channel(1); in new()47 closed_ch_tx: Some(closed_ch_tx), in new()89 self.closed_ch_tx.take(); in close()
1030 let (closed_ch_tx, closed_ch_rx) = broadcast::channel(1); in start_candidate()1034 *closed = Some(closed_ch_tx); in start_candidate()