Struct BatchOptions 

pub struct BatchOptions {
    pub max_concurrency: usize,
    pub return_exceptions: bool,
    pub wave_delay: Option<Duration>,
}

Settings for BatchProcessor.

Fields

max_concurrency: usize

Maximum in-flight tasks. 0 falls back to the config default.

return_exceptions: bool

When true, errors are collected per-input rather than short-circuiting the whole batch.

wave_delay: Option<Duration>

Optional pause between waves of scheduled tasks. None schedules continuously up to max_concurrency.

Implementations

impl BatchOptions

pub fn with_max_concurrency(self, n: usize) -> Self

Override max_concurrency (0 ⇒ use config’s value).

pub fn with_return_exceptions(self, on: bool) -> Self

Toggle return_exceptions.

pub fn with_wave_delay(self, d: Duration) -> Self

Set a wave delay between scheduled tasks.

Trait Implementations

impl Clone for BatchOptions

fn clone(&self) -> BatchOptions

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for BatchOptions

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl Default for BatchOptions

fn default() -> BatchOptions

Returns the “default value” for a type.