• Home
  • Raw
  • Download

Lines Matching full:notify

7 use tokio::sync::Notify;
12 impl AssertSend for Notify {} implementation
16 let notify = Notify::new(); in notify_notified_one() localVariable
17 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one()
19 notify.notify_one(); in notify_notified_one()
25 let notify = Notify::new(); in notified_one_notify() localVariable
26 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify()
30 notify.notify_one(); in notified_one_notify()
37 let notify = Notify::new(); in notified_multi_notify() localVariable
38 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
39 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify()
44 notify.notify_one(); in notified_multi_notify()
54 let notify = Notify::new(); in notify_notified_multi() localVariable
56 notify.notify_one(); in notify_notified_multi()
58 let mut notified1 = spawn(async { notify.notified().await }); in notify_notified_multi()
59 let mut notified2 = spawn(async { notify.notified().await }); in notify_notified_multi()
64 notify.notify_one(); in notify_notified_multi()
72 let notify = Notify::new(); in notified_drop_notified_notify() localVariable
73 let mut notified1 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
74 let mut notified2 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
82 notify.notify_one(); in notified_drop_notified_notify()
89 let notify = Notify::new(); in notified_multi_notify_drop_one() localVariable
90 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify_drop_one()
91 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify_drop_one()
96 notify.notify_one(); in notified_multi_notify_drop_one()
113 let notify = Arc::new(Notify::new()); in notify_in_drop_after_wake() localVariable
115 struct NotifyOnDrop(Arc<Notify>); in notify_in_drop_after_wake()
128 notify.notified().await; in notify_in_drop_after_wake()
132 let waker = futures::task::waker(Arc::new(NotifyOnDrop(notify.clone()))); in notify_in_drop_after_wake()
138 notify.notify_waiters(); in notify_in_drop_after_wake()
143 let notify = Notify::new(); in notify_one_after_dropped_all() localVariable
144 let mut notified1 = spawn(async { notify.notified().await }); in notify_one_after_dropped_all()
148 notify.notify_waiters(); in notify_one_after_dropped_all()
149 notify.notify_one(); in notify_one_after_dropped_all()
153 let mut notified2 = spawn(async { notify.notified().await }); in notify_one_after_dropped_all()
160 let notify = Notify::new(); in test_notify_one_not_enabled() localVariable
161 let mut future = spawn(notify.notified()); in test_notify_one_not_enabled()
163 notify.notify_one(); in test_notify_one_not_enabled()
169 let notify = Notify::new(); in test_notify_one_after_enable() localVariable
170 let mut future = spawn(notify.notified()); in test_notify_one_after_enable()
174 notify.notify_one(); in test_notify_one_after_enable()
181 let notify = Notify::new(); in test_poll_after_enable() localVariable
182 let mut future = spawn(notify.notified()); in test_poll_after_enable()
190 let notify = Notify::new(); in test_enable_after_poll() localVariable
191 let mut future = spawn(notify.notified()); in test_enable_after_poll()
199 let notify = Notify::new(); in test_enable_consumes_permit() localVariable
202 notify.notify_one(); in test_enable_consumes_permit()
204 let mut future1 = spawn(notify.notified()); in test_enable_consumes_permit()
207 let mut future2 = spawn(notify.notified()); in test_enable_consumes_permit()
217 let notify = Notify::new(); in test_waker_update() localVariable
218 let mut future = spawn(notify.notified()); in test_waker_update()
224 notify.notify_one(); in test_waker_update()