Struct batch_processing::tokio::step::AsyncStep

pub struct AsyncStep {
    pub name: String,
    pub throw_tolerant: Option<bool>,
    /* private fields */
}

Represents an asynchronous step with configurable callbacks and deciders.

Fields

name: String

The name of the step.

throw_tolerant: Option<bool>

Whether the step is tolerant to thrown errors.

Trait Implementations

impl AsyncStepRunner<StepStatus> for AsyncStep

fn run<'async_trait>( self ) -> Pin<Box<dyn Future<Output = StepStatus> + Send + 'async_trait>>

where Self: 'async_trait,

Executes the asynchronous step and returns its status.

impl Decider for AsyncStep

fn decide<'life0, 'async_trait>( &'life0 self ) -> Pin<Box<dyn Future<Output = bool> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait,

Decides whether the step should proceed or not based on the decider callback.

impl Send for AsyncStep