Struct TypedProducer 

pub struct TypedProducer<S, T, C> { /* private fields */ }

The producer half of a typed queue. Clone it for multiple producers.

Implementations

impl<S: Store, T, C: Codec<T>> TypedProducer<S, T, C>

pub fn push(&self, value: &T) -> Result<(), TypedPushError<S::Error>>

Encode and push value, waiting while the queue is at capacity.

pub fn close(&self)

Close the queue; further pushes fail and the consumer drains what remains.

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, T, C: Clone> Clone for TypedProducer<S, T, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.