Struct batch_processing::tokio::step::simple_step::AsyncSimpleStepBuilder

pub struct AsyncSimpleStepBuilder { /* private fields */ }

A builder struct for constructing asynchronous simple steps.

Trait Implementations

impl AsyncSimpleStepBuilderTrait<fn(), fn()> for AsyncSimpleStepBuilder

fn tasklet(self, step_callback: Box<DynAsyncCallback<()>>) -> Self

Sets the tasklet for the step.

Arguments

• step_callback - The callback function for the step.

Returns Self

Returns a modified builder instance.

impl AsyncStepBuilderTrait for AsyncSimpleStepBuilder

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

Sets the step to be tolerant to thrown errors.

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.

Panics

Panics if tasklet or name is not provided.

Returns Self

Returns a modified builder instance if validation succeeds.

fn build(self) -> AsyncStep

Builds and returns the configured asynchronous step.

Returns AsyncStep

Returns the configured asynchronous step.