Struct LazyQueue

pub struct LazyQueue<Item> { /* private fields */ }

A clonable thread safe sink-like queue.

Implementations

impl<Item> LazyQueue<Item>

pub fn new<F, I>( processor: F, queue_len: usize, ) -> (Self, QueueProcessor<Item, F, I>)

where F: FnMut(Item) -> I, I: Future,

Creates a new lazy queue using given processor.

impl<Item: Debug> LazyQueue<Item>

pub async fn send(&mut self, item: Item) -> Result<(), SendError<Item>>

Sends a value, waiting until there is capacity.

See tokio::sync::mpsc::Sender::send for more details.

Trait Implementations

impl<Item> Clone for LazyQueue<Item>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.