Struct WaiterQueue 

pub struct WaiterQueue<T> { /* private fields */ }

Implementations

impl<T: IFulfillment> WaiterQueue<T>

pub fn new() -> Self

pub fn lock(&self) -> WaiterQueueGuard<'_, T>

pub fn notify_one_local(&self, fulfillment: T) -> Option<T>

impl WaiterQueue<()>

pub fn notify_one(&self) -> bool

Returns true if a waiter was notified.

pub fn notify_all(&self) -> usize

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

Safety

You must cancel the returned waiter before it is dropped.

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

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

Trait Implementations

impl<T> Send for WaiterQueue<T>

impl<T> Sync for WaiterQueue<T>