Struct WakerQueue

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

A ConcurrentQueue with a Waker attached. Allows rapid implementation of fast channels where at least one side may not be cloned. Caution: Last Write wins and you are asking for trouble if there are races registering Wakers. See atomic_waker for details.

Implementations

impl<T: 'static + Send> WakerQueue<T>

pub fn bounded(size: usize) -> WakerQueue<T>

Create a WakerQueue with the given capacity.

pub fn unbounded() -> WakerQueue<T>

Create a WakerQueue which will dynamically resize as required.

pub fn is_empty(&self) -> bool

true if the WakerQueue has no items.

pub fn is_full(&self) -> bool

true if the WakerQueue has no spare capacity.

pub fn len(&self) -> usize

Count of items in the WakerQueue

pub fn capacity(&self) -> Option<usize>

Returns the maximum capacity of the queue. None for unbounded queues.

pub fn close(&self)

Closes the queue so that no more items can be pushed. Pops are allowed.

pub fn is_closed(&self) -> bool

true if the queue is closed

pub fn try_push(&self, value: T) -> Result<(), PushError<T>>

Attempt to push an item into the queue. Will fail if the queue is full or closed.

pub fn try_push_wake(&self, value: T, wake: bool) -> Result<(), PushError<T>>

Attempts a push. If successful and wake is true, wakes the last registered Waker.

pub fn try_push_wake_empty(&self, value: T) -> Result<(), PushError<T>>

Attempts a push. If successful and the queue was previously empty, wakes the last registered Waker.

pub fn try_push_wake_full(&self, value: T) -> Result<(), PushError<T>>

Attempts a push. If successful and wake is true, wakes the last registered Waker.

pub fn try_pop(&self) -> Result<T, PopError>

Attempts to pop an item from the queue. Will fail if the queue is empty.

pub fn try_pop_wake(&self, wake: bool) -> Result<T, PopError>

Attempts a pop. If successful and wake is true, wakes the last registered Waker.

pub fn try_pop_wake_empty(&self) -> Result<T, PopError>

Attempts a pop. If successful and the queue was previously empty, wakes the last registered Waker.

pub fn try_pop_wake_full(&self) -> Result<T, PopError>

Attempts a pop. If successful and the queue was previously full, wakes the last registered Waker.

pub fn push<'a, F>(&'a self, value: T, wake_if: F) -> Push<'a, T, F>

where F: Fn(&'a WakerQueue<T>) -> bool,

Returns a future which pushes into a WakerQueue

pub fn pop<'a, F>(&'a self, wake_if: F) -> Pop<'a, T, F>

where F: Fn(&'a WakerQueue<T>) -> bool,

Returns a future which pops from a WakerQueue

pub fn register(&self, waker: &Waker)

Registers a waker with the WakerQueue.

pub fn wake(&self)

Wakes the last registered Waker, if any.

pub fn wake_if(&self, wake: bool)

Wakes the last registered Waker, if any, if wake is true.

pub fn poll_pop(&self, ctx: &Context<'_>) -> Result<T, PopError>

Attempts to pop. If it fails because the queue is empty, it registers the Waker from the provided context.

pub fn poll_push(&self, value: T, ctx: &Context<'_>) -> Result<(), PushError<T>>

Attempts to push. If it fails because the queue is full, it registers the Waker from the provided context.

Trait Implementations

impl<T: Debug> Debug for WakerQueue<T>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<T: 'static + Send> Send for WakerQueue<T>

impl<T: 'static + Send> Sync for WakerQueue<T>