Searched refs:Notify (Results 1 – 11 of 11) sorted by relevance
| /webrtc/util/src/buffer/ |
| H A D | mod.rs | 7 use tokio::sync::{Mutex, Notify};
100 notify: Arc<Notify>,
118 notify: Arc::new(Notify::new()), in new()
|
| /webrtc/examples/examples/save-to-disk-h264/ |
| H A D | save-to-disk-h264.rs | 6 use tokio::sync::{Mutex, Notify};
27 notify: Arc<Notify>, in save_to_disk() argument
200 let notify_tx = Arc::new(Notify::new()); in main()
|
| /webrtc/examples/examples/save-to-disk-vpx/ |
| H A D | save-to-disk-vpx.rs | 6 use tokio::sync::{Mutex, Notify};
28 notify: Arc<Notify>, in save_to_disk() argument
225 let notify_tx = Arc::new(Notify::new()); in main()
|
| /webrtc/webrtc/src/sctp_transport/ |
| H A D | mod.rs | 33 use tokio::sync::{Mutex, Notify};
51 notify_rx: Arc<Notify>,
94 notify_tx: Arc<Notify>,
120 notify_tx: Arc::new(Notify::new()), in new()
|
| /webrtc/webrtc/src/data_channel/ |
| H A D | mod.rs | 26 use tokio::sync::{Mutex, Notify};
86 pub(crate) notify_tx: Arc<Notify>,
115 notify_tx: Arc::new(Notify::new()), in new()
300 notify_rx: Arc<Notify>, in read_loop() argument
|
| /webrtc/webrtc/src/rtp_transceiver/rtp_sender/ |
| H A D | mod.rs | 23 use tokio::sync::{mpsc, Mutex, Notify};
30 pub(crate) stop_called_rx: Arc<Notify>,
115 stop_called_tx: Arc<Notify>,
145 let stop_called_tx = Arc::new(Notify::new()); in new()
|
| /webrtc/examples/examples/insertable-streams/ |
| H A D | insertable-streams.rs | 8 use tokio::sync::Notify;
147 let notify_tx = Arc::new(Notify::new()); in main()
|
| /webrtc/examples/examples/ortc/ |
| H A D | ortc.rs | 6 use tokio::sync::Notify;
98 let done = Arc::new(Notify::new()); in main()
|
| /webrtc/examples/examples/play-from-disk-h264/ |
| H A D | play-from-disk-h264.rs | 8 use tokio::sync::Notify;
137 let notify_tx = Arc::new(Notify::new()); in main()
|
| /webrtc/examples/examples/play-from-disk-vpx/ |
| H A D | play-from-disk-vpx.rs | 8 use tokio::sync::Notify;
143 let notify_tx = Arc::new(Notify::new()); in main()
|
| /webrtc/sctp/src/stream/ |
| H A D | mod.rs | 24 sync::{mpsc, Mutex, Notify},
78 pub(crate) read_notifier: Notify,
134 read_notifier: Notify::new(), in new()
|