Searched refs:reader_close_tx (Results 1 – 2 of 2) sorted by relevance
103 reader_close_tx: Mutex<Option<mpsc::Sender<()>>>, field259 let (reader_close_tx, mut reader_close_rx) = mpsc::channel(1); in new()288 reader_close_tx: Mutex::new(Some(reader_close_tx)), in new()475 let mut reader_close_tx = self.reader_close_tx.lock().await; in close() localVariable476 reader_close_tx.take(); in close()
437 reader_close_tx: Mutex::new(None), in test_export_keying_material()