Struct nolock::queues::spsc::unbounded::AsyncUnboundedReceiver

pub struct AsyncUnboundedReceiver<T> { /* fields omitted */ }

This is the async Variant of the UnboundedReceiver.

Created using async_queue

Implementations

impl<T> AsyncUnboundedReceiver<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Producer

pub fn dequeue<'queue>(&'queue mut self) -> DequeueFuture<'queue, T>

Dequeues the next Item from the Queue

pub fn try_dequeue(&mut self) -> Result<T, DequeueError>

This attempts to dequeue the next Item from the Queue.

This behaves just like the normal try_dequeue-Operation

Trait Implementations

impl<T> Debug for AsyncUnboundedReceiver<T>

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

Formats the value using the given formatter.