Struct WaiterQueue 

pub struct WaiterQueue { /* private fields */ }

Implementations

impl WaiterQueue

pub fn new() -> Self

pub fn waiter_count(&self) -> usize

pub unsafe fn wait(&self) -> Waiter<'_>

Safety

You must call cancel on the returned waiter before it is dropped.

pub async fn wait_for<T>(&self, condition: impl FnMut() -> Option<T>) -> T

pub async fn wait_until(&self, condition: impl FnMut() -> bool)

pub fn notify(&self, count: usize) -> usize

pub fn notify_all(&self) -> usize

Notify all current waiters. Return the number of waiters notified.