Struct batch_processing::tokio::step::complex_step::AsyncComplexStepBuilder

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

An asynchronous complex step builder for processing data.

Trait Implementations

impl<I: Sized + Send + 'static + Unpin + Sync, O: Sized + Send + 'static + Sync> AsyncStepBuilderTrait for AsyncComplexStepBuilder<I, O>

where Self: Sized,

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

Sets the decider for the step.

Parameters

• decider: A callback function for deciding the flow of the step.

Returns Self

The modified builder instance.

fn throw_tolerant(self) -> Self

Sets the step to be tolerant to exceptions.

Returns Self

The modified builder instance.

fn get(name: String) -> Self

Retrieves a new step builder instance with a given name.

Parameters

• name: The name of the step.

Returns Self

A new step builder instance.

fn validate(self) -> Self

Validates the step builder instance.

Returns Self

The validated builder instance.

fn build(self) -> AsyncStep

Builds and returns the asynchronous step.

Returns AsyncStep

The built asynchronous step.

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

Implementation of ComplexStepBuilderTrait for AsyncComplexStepBuilder.

fn reader( self, reader: Box<DynAsyncCallback<Box<dyn Stream<Item = I> + Unpin + Send>>> ) -> Self

Sets the reader for the step.

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

Sets the processor for the step.

fn writer( self, writer: Box<dyn Send + Sync + Fn(Vec<O>) -> BoxFuture<'static, ()>> ) -> Self

Sets the writer for the step.

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

Sets the chunk size for processing data in chunks.