Struct Producer

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

Fifo Production Handle

This is the “sending” half of a FIFO channel.

When you call the methods of this object to send N items, a reservation of N consecutive slots is performed on the underlying FIFO. Then, once this reservation is negociated, all items are pushed into the slots sequentially.

Unlike Consumers, Producers implement Clone.

Example

let (tx, rx) = async_fifo::new();
 
// Sending items one by one
tx.send('a');
tx.send('b');
tx.send('c');
 
// Pouring items from a Vec
let mut vec = vec!['a', 'b', 'c'];
tx.send_iter(vec.drain(..));
 
// Sending an array of items
let array = ['a', 'b', 'c'];
tx.send_iter(array);
 
// Sending a slice of primitive items
let slice = ['a', 'b', 'c'].as_slice();
let iter = slice.iter().copied();
tx.send_iter(iter);
 
// Receiving a total of 12 items
let expected = ['a', 'b', 'c', 'a', 'b', 'c', 'a', 'b', 'c', 'a', 'b', 'c'];
assert_eq!(rx.try_recv_array(), Some(expected));
assert_eq!(rx.try_recv(), None);

Implementations

impl<T> Producer<T>

pub fn send_iter<I>(&self, into_iter: I)

where I: IntoIterator, I::IntoIter: ExactSizeIterator<Item = T>,

Sends a batch of items in the channel, atomically.

This operation is non-blocking and always succeeds immediately.

pub fn send(&self, item: T)

Sends one item through the channel.

This operation is non-blocking and always succeeds immediately.

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

fn drop(&mut self)

Executes the destructor for this type.