Struct Producer 

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

The producer half. Clone it for multiple producers.

Implementations

impl<S: Store> Producer<S>

pub fn push(&self, value: &[u8]) -> Result<(), PushError<S::Error>>

Append value, waiting while the queue is at capacity.

pub fn try_push(&self, value: &[u8]) -> Result<(), TryPushError<S::Error>>

Append value, or return TryPushError::Full instead of waiting.

pub fn close(&self)

Close the queue. Further pushes fail; the consumer can still drain.

pub fn len(&self) -> usize

Number of unacked items currently in the queue.

pub fn is_empty(&self) -> bool

Whether the queue holds no unacked items.

Trait Implementations

impl<S> Clone for Producer<S>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.