Struct atomic_batcher::Batcher

pub struct Batcher<T: Clone> { /* private fields */ }

Batching representation.

Implementations

impl<T: Clone> Batcher<T>

pub fn new(run: Arc<dyn Fn(Vec<T>, Batcher<T>) + Send + Sync>) -> Self

Create a new batcher with a run function.

pub fn append(&self, val: Vec<T>, cb: CbOption)

Accept an array of values and a callback. The accepted callback is called when the batch containing the values have been run.

pub fn done(self, err: Result<(), &'static str>)

Turn batcher’s running state to off. then call the run function.

Trait Implementations

impl<T: Clone + Clone> Clone for Batcher<T>

fn clone(&self) -> Batcher<T>

Returns a copy of the value.

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

Performs copy-assignment from source.