Lines Matching full:notify
1 use crate::sync::Notify;
14 let ptr = data as *const Notify; in notify_clones_waker_before_lock() constant
15 Arc::<Notify>::increment_strong_count(ptr); in notify_clones_waker_before_lock()
17 // Notify wait list is locked. in notify_clones_waker_before_lock()
23 drop(Arc::<Notify>::from_raw(data as *const Notify)); in notify_clones_waker_before_lock() constant
34 let notify = Arc::new(Notify::new()); in notify_clones_waker_before_lock() localVariable
35 let notify2 = notify.clone(); in notify_clones_waker_before_lock()
41 let future = notify.notified(); in notify_clones_waker_before_lock()
53 let notify = Arc::new(Notify::new()); in notify_waiters_handles_panicking_waker() localVariable
55 struct PanickingWaker(Arc<Notify>); in notify_waiters_handles_panicking_waker()
63 let bad_fut = notify.notified(); in notify_waiters_handles_panicking_waker()
66 let waker = futures::task::waker(Arc::new(PanickingWaker(notify.clone()))); in notify_waiters_handles_panicking_waker()
72 let mut fut = tokio_test::task::spawn(notify.notified()); in notify_waiters_handles_panicking_waker()
78 notify.notify_waiters(); in notify_waiters_handles_panicking_waker()
89 let notify = Notify::new(); in notify_simple() localVariable
91 let mut fut1 = tokio_test::task::spawn(notify.notified()); in notify_simple()
94 let mut fut2 = tokio_test::task::spawn(notify.notified()); in notify_simple()
97 notify.notify_waiters(); in notify_simple()