Searched refs:send_called_tx (Results 1 – 1 of 1) sorted by relevance
114 send_called_tx: SyncMutex<Option<mpsc::Sender<()>>>, field144 let (send_called_tx, send_called_rx) = mpsc::channel(1); in new()204 send_called_tx: SyncMutex::new(Some(send_called_tx)), in new()442 let mut send_called_tx = self.send_called_tx.lock(); in send() localVariable443 send_called_tx.take(); in send()497 let send_called_tx = self.send_called_tx.lock(); in has_sent() localVariable498 send_called_tx.is_none() in has_sent()