Searched refs:chan_state_tx (Results 1 – 1 of 1) sorted by relevance
35 pub(crate) chan_state_tx: Mutex<Option<mpsc::Sender<ConnectionState>>>, field86 let (chan_state_tx, chan_state_rx) = mpsc::channel(1); in new()107 chan_state_tx: Mutex::new(Some(chan_state_tx)), in new()321 let chan_state_tx = self.chan_state_tx.lock().await; in update_connection_state() localVariable322 if let Some(tx) = &*chan_state_tx { in update_connection_state()640 let mut chan_state_tx = self.chan_state_tx.lock().await; in close() localVariable641 chan_state_tx.take(); in close()