Struct StepExecutor 

pub struct StepExecutor<T> { /* private fields */ }

Sequential executor that runs Steps in order, reporting progress and honouring a CancellationToken.

Implementations

impl<T: Send + 'static> StepExecutor<T>

pub fn new(steps: Vec<Step<T>>) -> Self

Create a new executor with the given steps.

pub async fn execute( &self, input: T, on_progress: impl Fn(StepStatus) + Send, cancel: CancellationToken, ) -> AppResult<T>

Run all steps sequentially.

• Each step receives the output of the previous step (or input for the first).
• on_progress is called with StepStatus::Started and StepStatus::Completed (or StepStatus::Failed) for every step.
• If cancel is triggered, the executor stops between steps and returns ErrorCode::Cancelled.