Searched refs:stop_called_tx (Results 1 – 1 of 1) sorted by relevance
115 stop_called_tx: Arc<Notify>, field145 let stop_called_tx = Arc::new(Notify::new()); in new() localVariable146 let stop_called_rx = stop_called_tx.clone(); in new()205 stop_called_tx, in new()455 self.stop_called_tx.notify_waiters(); in stop()