Searched refs:decrypted_rx (Results 1 – 2 of 2) sorted by relevance
74 …decrypted_rx: Mutex<mpsc::Receiver<Result<Vec<u8>>>>, // Decrypted Application Data or error, pull… field254 let (decrypted_tx, decrypted_rx) = mpsc::channel(1); in new()274 decrypted_rx: Mutex::new(decrypted_rx), in new()396 let mut decrypted_rx = self.decrypted_rx.lock().await; in read() localVariable402 r = decrypted_rx.recv() => r, in read()406 decrypted_rx.recv().await in read()
395 let (_decrypted_tx, decrypted_rx) = mpsc::channel(1); in test_export_keying_material()423 decrypted_rx: Mutex::new(decrypted_rx), in test_export_keying_material()