Struct nolock::queues::spsc::unbounded::AsyncUnboundedSender

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

This is the async Variant of the UnboundedSender.

Created using async_queue

Implementations

impl<T> AsyncUnboundedSender<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Consumer

pub fn enqueue(&mut self, data: T) -> Result<(), (T, EnqueueError)>

Enqueues the given Data on the Queue

Trait Implementations

impl<T> Debug for AsyncUnboundedSender<T>

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

Formats the value using the given formatter.