Struct FixBatchStrategy

pub struct FixBatchStrategy<I> { /* private fields */ }

A strategy to batch items with a fixed batch size.

Implementations

impl<I> FixBatchStrategy<I>

pub fn new(batch_size: usize) -> FixBatchStrategy<I>

Creates a new strategy to batch items with a fixed batch size.

Arguments

• batch_size - The batch size.

Returns

The strategy.

Trait Implementations

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

where I: Send + Sync + 'static,

fn add(&mut self, item: I)

Adds an item to the strategy.

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

Batches the items.

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

Creates a new strategy of the same type.

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

Returns the expected batch size for this strategy.