Searched refs:cancel_tx (Results 1 – 2 of 2) sorted by relevance
61 cancel_tx: Option<mpsc::Sender<()>>, field151 let (cancel_tx, cancel_rx) = mpsc::channel(1); in start()155 internal.cancel_tx = Some(cancel_tx); in start()226 internal.cancel_tx.take(); in stop()
1823 let (cancel_tx, mut cancel_rx) = mpsc::channel::<()>(1); in test_agent_restart_one_side()1824 let cancel_tx = Arc::new(Mutex::new(Some(cancel_tx))); in test_agent_restart_one_side() localVariable1826 let cancel_tx_clone = Arc::clone(&cancel_tx); in test_agent_restart_one_side()