Struct WorkSender

pub struct WorkSender<K, C, O> { /* private fields */ }

A clonable handle to the work queue. When all clones of WorkSender are dropped, the queue will process all remaining requests and terminate its output stream.

Implementations

impl<K, C, O> WorkSender<K, C, O>

where K: Clone + Eq + Hash, C: TryMerge, O: Clone,

pub fn push( &self, key: K, context: C, ) -> impl Future<Output = Result<O, Closed>>

Enqueue the given key to be processed by a worker, or attach to an existing request to process this key.

pub fn push_all( &self, entries: impl Iterator<Item = (K, C)>, ) -> impl Iterator<Item = impl Future<Output = Result<O, Closed>>>

Enqueue all the given keys to be processed by a worker, merging them with existing known tasks if possible, returning an iterator of the futures that will resolve to the results of processing the keys.

This method is similar to, but more efficient than, mapping an iterator to WorkSender::push.

Trait Implementations

impl<K, C, O> Clone for WorkSender<K, C, O>

fn clone(&self) -> Self

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<K, C, O> Debug for WorkSender<K, C, O>

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

Formats the value using the given formatter.