Struct nolock::queues::mpmc::bounded::scq::Sender

pub struct Sender<T>(_);

The sending Half for a SCQ based MPMC-Queue

Implementations

impl<T> Sender<T>

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

Attempts to Enqueue the given Data

Example

Valid/Normal enqueue

let (rx, tx) = scq::queue::<u64>(10);

assert_eq!(Ok(()), tx.try_enqueue(13));

Queue is already full

let (rx, tx) = scq::queue::<u64>(1);
// Enqueue an Element to fill the Queue
tx.try_enqueue(13);

assert_eq!(Err((EnqueueError::Full, 13)), tx.try_enqueue(13));

pub fn is_closed(&self) -> bool

Checks if the Receiving Half has closed the Queue, meaning that no more Elements would be dequeued from the Queue and therefore also should not be inserted anymore.

Example

let (rx, tx) = scq::queue::<u64>(10);

assert_eq!(false, tx.is_closed());

drop(rx);

assert_eq!(true, tx.is_closed());

Trait Implementations

impl<T> Debug for Sender<T>

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

Formats the value using the given formatter.