Struct Producer 

pub struct Producer<T> { /* private fields */ }

The producer endpoint of an MPSC queue.

This endpoint can be cloned to create additional producers. Each clone maintains its own cached state for performance.

Implementations

impl<T> Producer<T>

pub fn push(&self, value: T) -> Result<(), Full<T>>

Pushes a value into the queue.

Returns Err(Full(value)) if the queue is full, returning ownership of the value to the caller for backpressure handling.

This method spins internally on CAS contention but returns immediately when the queue is actually full.

pub fn capacity(&self) -> usize

Returns the capacity of the queue.

pub fn is_disconnected(&self) -> bool

Returns true if the consumer has been dropped.

With multiple producers, this returns true only when this is the last handle (all other producers and the consumer are dropped).

Trait Implementations

impl<T> Clone for Producer<T>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<T> Debug for Producer<T>

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

Formats the value using the given formatter.

impl<T: Send> Send for Producer<T>