Lines Matching refs:notify

13     let notify = Notify::new();  in notify_notified_one()  localVariable
14 let mut notified = spawn(async { notify.notified().await }); in notify_notified_one()
16 notify.notify_one(); in notify_notified_one()
22 let notify = Notify::new(); in notified_one_notify() localVariable
23 let mut notified = spawn(async { notify.notified().await }); in notified_one_notify()
27 notify.notify_one(); in notified_one_notify()
34 let notify = Notify::new(); in notified_multi_notify() localVariable
35 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify()
36 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify()
41 notify.notify_one(); in notified_multi_notify()
51 let notify = Notify::new(); in notify_notified_multi() localVariable
53 notify.notify_one(); in notify_notified_multi()
55 let mut notified1 = spawn(async { notify.notified().await }); in notify_notified_multi()
56 let mut notified2 = spawn(async { notify.notified().await }); in notify_notified_multi()
61 notify.notify_one(); in notify_notified_multi()
69 let notify = Notify::new(); in notified_drop_notified_notify() localVariable
70 let mut notified1 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
71 let mut notified2 = spawn(async { notify.notified().await }); in notified_drop_notified_notify()
79 notify.notify_one(); in notified_drop_notified_notify()
86 let notify = Notify::new(); in notified_multi_notify_drop_one() localVariable
87 let mut notified1 = spawn(async { notify.notified().await }); in notified_multi_notify_drop_one()
88 let mut notified2 = spawn(async { notify.notified().await }); in notified_multi_notify_drop_one()
93 notify.notify_one(); in notified_multi_notify_drop_one()
110 let notify = Arc::new(Notify::new()); in notify_in_drop_after_wake() localVariable
125 notify.notified().await; in notify_in_drop_after_wake()
129 let waker = futures::task::waker(Arc::new(NotifyOnDrop(notify.clone()))); in notify_in_drop_after_wake()
135 notify.notify_waiters(); in notify_in_drop_after_wake()
140 let notify = Notify::new(); in notify_one_after_dropped_all() localVariable
141 let mut notified1 = spawn(async { notify.notified().await }); in notify_one_after_dropped_all()
145 notify.notify_waiters(); in notify_one_after_dropped_all()
146 notify.notify_one(); in notify_one_after_dropped_all()
150 let mut notified2 = spawn(async { notify.notified().await }); in notify_one_after_dropped_all()