Struct nolock::queues::spsc::bounded::AsyncBoundedSender

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

An async variant of the BoundedSender that allows your to efficiently use this Queue in async Contexts as well.

Created using the async_queue method

Implementations

impl<T> AsyncBoundedSender<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Consumer

pub fn enqueue<'queue>(&'queue mut self, data: T) -> EnqueueFuture<'queue, T>

The async variant of the blocking enqueue operation on the Non-Async version of the Queue

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

Attempts to enqueue the given Data on the Queue.

This behaves just like the try_enqueue operation on the normal sync-BoundedSender

pub fn is_full(&self) -> bool

Checks if the Queue is currently Full

Trait Implementations

impl<T> Debug for AsyncBoundedSender<T>

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

Formats the value using the given formatter.