(&self)
| 33 | } |
| 34 | |
| 35 | pub fn notify(&self) { |
| 36 | if self |
| 37 | .enable |
| 38 | .compare_exchange(false, true, Ordering::SeqCst, Ordering::SeqCst) |
| 39 | .is_ok() |
| 40 | { |
| 41 | self.lock_ops.notify(usize::MAX); |
| 42 | } |
| 43 | } |
| 44 | #[allow(dead_code)] |
| 45 | pub async fn wait(&self) { |
| 46 | let mut listener = None; |