Struct batch_aint_one::Batcher

pub struct Batcher<K, I, O = (), E = String> { /* 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.

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, batching_strategy: BatchingStrategy) -> 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> Clone for Batcher<K, I, 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: Debug, I: Debug, O: Debug, E: Debug> Debug for Batcher<K, I, O, E>

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

Formats the value using the given formatter.