Struct nolock::queues::mpsc::jiffy::Sender

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

One of the Sender, created by calling queue

Implementations

impl<T> Sender<T>

pub fn is_closed(&self) -> bool

Checks if the Queue has been closed by the Consumer

Example:

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

// The receiver gets dropped and is therefore now considered closed
drop(rx);

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

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

Enqueues the given Data on the queue

Returns

If the Data was sucessfully enqueued Ok will be returned, otherwise it will return the right Error according to the EnqueueError. However as this is an unbounded-Queue, the only real reason for a failure is when the receiving Side was dropped/closed.

Example

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

// Enqueue some Data
tx.enqueue(13);
tx.enqueue(14);
tx.enqueue(15);

Trait Implementations

impl<T> Debug for Sender<T>

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

Formats the value using the given formatter.

impl<T> Drop for Sender<T>

fn drop(&mut self)

Executes the destructor for this type.