Searched refs:notify_tx (Results 1 – 8 of 8) sorted by relevance
137 let notify_tx = Arc::new(Notify::new()); in main() localVariable138 let notify_video = notify_tx.clone(); in main()139 let notify_audio = notify_tx.clone(); in main()295 notify_tx.notify_waiters(); in main()
143 let notify_tx = Arc::new(Notify::new()); in main() localVariable144 let notify_video = notify_tx.clone(); in main()145 let notify_audio = notify_tx.clone(); in main()306 notify_tx.notify_waiters(); in main()
147 let notify_tx = Arc::new(Notify::new()); in main() localVariable148 let notify_video = notify_tx.clone(); in main()203 notify_tx.notify_waiters(); in main()
94 notify_tx: Arc<Notify>, field120 notify_tx: Arc::new(Notify::new()), in new()151 _ = self.notify_tx.notified() => { in start()178 notify_rx: self.notify_tx.clone(), in start()210 self.notify_tx.notify_waiters(); in stop()
200 let notify_tx = Arc::new(Notify::new()); in main() localVariable201 let notify_rx = notify_tx.clone(); in main()263 notify_tx.notify_waiters(); in main()
225 let notify_tx = Arc::new(Notify::new()); in main() localVariable226 let notify_rx = notify_tx.clone(); in main()293 notify_tx.notify_waiters(); in main()
86 pub(crate) notify_tx: Arc<Notify>, field115 notify_tx: Arc::new(Notify::new()), in new()278 let notify_rx = self.notify_tx.clone(); in handle_open()429 self.notify_tx.notify_waiters(); in close()
252 if let Some(notify_tx) = &self.alloc_close_notify { in close()253 let _ = notify_tx in close()