Struct ComplexStepBuilder

pub struct ComplexStepBuilder<I: Sized, O: Sized> { /* private fields */ }

A builder struct for constructing complex synchronous steps.

Trait Implementations

impl<I: Sized + 'static, O: Sized + 'static> ComplexStepBuilderTrait<I, O> for ComplexStepBuilder<I, O>

fn reader( self, reader: Box<dyn Fn() -> Box<dyn Iterator<Item = I>> + Send>, ) -> Self

Sets the reader function for the step.

fn processor( self, processor: Box<dyn Fn() -> Box<dyn Fn(I) -> O> + Send>, ) -> Self

Sets the processor function for the step.

fn writer(self, writer: Box<dyn Fn() -> Box<dyn Fn(&Vec<O>)> + Send>) -> Self

Sets the writer function for the step.

fn chunk_size(self, chunk_size: usize) -> Self

Sets the chunk size for processing data in chunks.

impl<I: Sized + 'static, O: Sized + 'static> StepBuilderTrait for ComplexStepBuilder<I, O>

where Self: Sized,

fn decider(self, decider: DeciderCallback) -> Self

Sets the decider callback for the step.

Arguments

• decider - The decider callback function.

Returns Self

Returns a modified builder instance.

fn throw_tolerant(self) -> Self

Configures the step to be tolerant to thrown exceptions.

Returns Self

Returns a modified builder instance.

fn get(name: String) -> Self

Initializes a new builder instance with the given name.

Arguments

• name - The name of the step.

Returns Self

Returns a new builder instance.

fn validate(self) -> Self

Validates the builder configuration.

Returns Self

Returns a modified builder instance if validation succeeds.

fn build(self) -> SyncStep

Builds and returns the configured synchronous step.

Returns SyncStep

Returns the configured synchronous step.