Trait BatchStrategy

pub trait BatchStrategy<I>: Send + Sync {
    // Required methods
    fn add(&mut self, item: I);
    fn batch(&mut self, force: bool) -> Option<Vec<I>>;
    fn clone_dyn(&self) -> Box<dyn BatchStrategy<I>>;
    fn batch_size(&self) -> Option<usize>;
}

A strategy to batch items.

Required Methods

fn add(&mut self, item: I)

Adds an item to the strategy.

Arguments

• item - The item to add.

fn batch(&mut self, force: bool) -> Option<Vec<I>>

Batches the items.

Arguments

• force - Whether to force batching.

Returns

The batched items.

fn clone_dyn(&self) -> Box<dyn BatchStrategy<I>>

Creates a new strategy of the same type.

Returns

The new strategy.

fn batch_size(&self) -> Option<usize>

Returns the expected batch size for this strategy.

Returns

The batch size, or None if the strategy doesn’t have a fixed batch size.

Implementors

impl<I> BatchStrategy<I> for FixBatchStrategy<I>

where I: Send + Sync + 'static,