Struct nolock::queues::spsc::unbounded::UnboundedSender

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

The Sender-Half of an unbounded Queue

Implementations

impl<T> UnboundedSender<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Consumer

Example

let (rx, tx) = unbounded::queue::<usize>();

// Drop the Consumer and therefore also close the Queue
drop(rx);

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

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

Enqueues the Data

Example

Normal Enqueue, where the Queue is not closed

let (rx, mut tx) = unbounded::queue::<usize>();

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

Failed Enqueue, the Queue has been closed

let (rx, mut tx) = unbounded::queue::<usize>();

// Drop the Consumer and therefore also close the Queue
drop(rx);

assert_eq!(Err((13, EnqueueError::Closed)), tx.enqueue(13));

Trait Implementations

impl<T> Debug for UnboundedSender<T>

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

Formats the value using the given formatter.

impl<T> Drop for UnboundedSender<T>

fn drop(&mut self)

Executes the destructor for this type.

impl<T> Send for UnboundedSender<T>

impl<T> Sync for UnboundedSender<T>