Trait batch_processing::tokio::step::step_builder::AsyncStepBuilderTrait

source · 
pub trait AsyncStepBuilderTrait {
    // Required methods
    fn decider(self, decider: DeciderCallback) -> Self;
    fn throw_tolerant(self) -> Self;
    fn get(name: String) -> Self;
    fn validate(self) -> Self;
    fn build(self) -> AsyncStep;
}
Expand description

A trait for building asynchronous steps.

Required Methods§

source

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.

source

fn throw_tolerant(self) -> Self

Sets the step to be tolerant to thrown errors.

§Returns Self

Returns a modified builder instance.

source

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.

source

fn validate(self) -> Self

Validates the builder configuration.

§Returns Self

Returns a modified builder instance if validation succeeds.

source

fn build(self) -> AsyncStep

Builds and returns the configured asynchronous step.

§Returns AsyncStep

Returns the configured asynchronous step.

Object Safety§

This trait is not object safe.

Implementors§