Struct Producer 

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

Producer handle for sending items into a channel.

Cloning a producer triggers automatic SPSC → MPSC upgrade.

Implementations

impl<T> Producer<T>

pub fn push(&self, item: T) -> Result<(), StreamingError>

Pushes an item to the channel, blocking if necessary.

Behavior depends on the backpressure strategy:

• Block: Waits until space is available
• DropOldest: Drops the oldest item to make room
• Reject: Returns error immediately if full

Errors

Returns StreamingError::ChannelClosed if all consumers have dropped. Returns StreamingError::ChannelFull if strategy is Reject and buffer is full.

pub fn try_push(&self, item: T) -> Result<(), TryPushError<T>>

Tries to push an item without blocking.

Returns Ok(()) if successful, or Err(TryPushError) containing the item if the push failed.

Errors

Returns TryPushError if the channel is full or closed.

pub fn push_batch(&self, items: impl IntoIterator<Item = T>) -> usize

Pushes multiple items, returning the number successfully pushed.

Stops at the first failure (full buffer or closed channel).

pub fn is_mpsc(&self) -> bool

Returns true if the channel is in MPSC mode.

pub fn mode(&self) -> ChannelMode

Returns the channel mode.

pub fn is_closed(&self) -> bool

Returns true if the channel is closed.

pub fn len(&self) -> usize

Returns the number of items currently in the buffer.

pub fn is_empty(&self) -> bool

Returns true if the buffer is empty.

pub fn capacity(&self) -> usize

Returns the buffer capacity.

pub fn stats(&self) -> ChannelStats

Returns statistics for this channel.

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> Debug for Producer<T>

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

Formats the value using the given formatter.

impl<T> Drop for Producer<T>

fn drop(&mut self)

Executes the destructor for this type.