Struct Step 

pub struct Step<I, O> { /* private fields */ }

A typed operation in a sequential chain.

Implementations

impl<I, O> Step<I, O>

where I: Send + 'static, O: Send + 'static,

pub fn new<F, Fut>( id: impl Into<String>, name: impl Into<String>, execute: F, ) -> Self

where F: Fn(I, StepContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = AppResult<O>> + Send + 'static,

Create a typed chain step.

pub fn from_fn<F, Fut>(id: impl Into<String>, execute: F) -> Self

where F: Fn(I, StepContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = AppResult<O>> + Send + 'static,

Create a typed chain step using id as the display name.

pub fn with_cleanup<F, Fut>(self, cleanup: F) -> Self

where F: Fn() -> Fut + Send + Sync + 'static, Fut: Future<Output = AppResult<()>> + Send + 'static,

Register cleanup to run only if a later step fails or cancellation interrupts the chain.

pub fn id(&self) -> &str

Unique step identifier.

pub fn name(&self) -> &str

Human-readable step name.