Struct BatchExecutor 

pub struct BatchExecutor { /* private fields */ }

Implementations

impl BatchExecutor

pub fn new() -> Self

pub fn with_config(config: BatchExecutorConfig) -> Self

pub fn config(&self) -> &BatchExecutorConfig

pub async fn execute_sequential<T, R, E, F, Fut>( &self, items: Vec<BatchItem<T>>, executor_fn: F, ) -> BatchResult<R, BatchError>

where F: Fn(T) -> Fut, Fut: Future<Output = Result<R, E>>, E: Display,

Trait Implementations

impl Default for BatchExecutor

fn default() -> Self

Returns the “default value” for a type.