Struct Batcher 

pub struct Batcher<K, I, O = (), E = String>
where
    K: 'static + Send + Eq + Hash + Clone,
    I: 'static + Send,
    O: 'static + Send,
    E: 'static + Send + Clone + Display,
{ /* private fields */ }

Groups items to be processed in batches.

Takes inputs (I) grouped by a key (K) and processes multiple together in a batch. An output (O) is produced for each input.

Errors (E) can be returned from a batch.

Cheap to clone.

Implementations

impl<K, I, O, E> Batcher<K, I, O, E>

where K: 'static + Send + Eq + Hash + Clone, I: 'static + Send, O: 'static + Send, E: 'static + Send + Clone + Display,

pub fn new<F>( processor: F, limits: Limits, batching_policy: BatchingPolicy, ) -> Self

where F: 'static + Send + Clone + Processor<K, I, O, E>,

Create a new batcher.

pub async fn add(&self, key: K, input: I) -> Result<O, BatchError<E>>

Add an item to the batch and await the result.

Trait Implementations

impl<K, I, O, E> Clone for Batcher<K, I, O, E>

where K: 'static + Send + Eq + Hash + Clone, I: 'static + Send, O: 'static + Send, E: 'static + Send + Clone + Display,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K, I, O, E> Debug for Batcher<K, I, O, E>

where K: 'static + Send + Eq + Hash + Clone + Debug, I: 'static + Send + Debug, O: 'static + Send + Debug, E: 'static + Send + Clone + Display + Debug,

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

Formats the value using the given formatter.