Struct SequentialBatchProcessorBuilder 

pub struct SequentialBatchProcessorBuilder<Item> { /* private fields */ }

Builder for SequentialBatchProcessor.

Use the builder when the default progress interval or reporter should be customized.

use std::time::Duration;

use qubit_batch::SequentialBatchProcessor;

let processor = SequentialBatchProcessor::builder(|_item: &i32| {})
    .report_interval(Duration::ZERO)
    .build();

assert_eq!(processor.report_interval(), Duration::ZERO);

Implementations

impl<Item> SequentialBatchProcessorBuilder<Item>

pub fn new<C>(consumer: C) -> Self

where C: Consumer<Item> + 'static,

Creates a builder from a consumer.

Parameters

• consumer - Consumer invoked once for each input item.

Returns

A builder initialized with default sequential processor settings.

pub const fn report_interval(self, report_interval: Duration) -> Self

Sets the progress-report interval.

Parameters

• report_interval - Minimum time between due-based running progress callbacks. Duration::ZERO reports at every sequential between-item progress point.

Returns

This builder for fluent configuration.

pub fn reporter<R>(self, reporter: R) -> Self

where R: ProgressReporter + 'static,

Sets the progress reporter used by built processors.

Parameters

• reporter - Progress reporter used for later processing calls.

Returns

This builder for fluent configuration.

pub fn reporter_arc(self, reporter: Arc<dyn ProgressReporter>) -> Self

Sets the shared progress reporter used by built processors.

Parameters

• reporter - Shared progress reporter used for later processing calls.

Returns

This builder for fluent configuration.

pub fn no_reporter(self) -> Self

Disables progress callbacks by using NoOpProgressReporter.

Returns

This builder for fluent configuration.

pub fn build(self) -> SequentialBatchProcessor<Item>

Builds a SequentialBatchProcessor.

Returns

A sequential batch processor with this builder’s configuration.