Struct nolock::queues::mpsc::jiffy::AsyncSender

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

This is the asynchronous Version of the Jiffy-Sender

Implementations

impl<T> AsyncSender<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Consumer

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

Enqueues the given Data

Example:

async fn demo() {
  let (mut rx, tx) = jiffy::async_queue::<usize>();

  // Enqueue the given Data
  assert_eq!(Ok(()), tx.enqueue(13));
   
}

Trait Implementations

impl<T> Debug for AsyncSender<T>

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

Formats the value using the given formatter.