Struct Batcher

pub struct Batcher<E>
where
    E: BatchExecutor + Send + Sync + 'static,
{ /* private fields */ }

A batcher used to batch requests to a BatchExecutor

Implementations

impl<E> Batcher<E>

where E: BatchExecutor + Send + Sync + 'static,

pub fn new( executor: E, batch_size: usize, concurrency: usize, delay: Duration, ) -> Self

Create a new batcher

pub const fn builder() -> BatcherBuilder<E>

Create a builder for a Batcher

pub async fn execute(&self, items: E::Request) -> Option<E::Response>

Execute a single request

pub async fn execute_many<I>(&self, items: I) -> Vec<Option<E::Response>>

where I: IntoIterator<Item = E::Request>,

Execute many requests