Struct Phases 

pub struct Phases<'a> { /* private fields */ }

A fixed set of owned phases, selected by index rather than automatic sequence. A failed attempt leaves other phases available. The library decides whether to recover, retry, or propagate its error. Hand the final result to complete to resolve untouched phases; Drop without that handoff records abandonment.

Implementations

impl<'a> Phases<'a>

pub fn new( parent: &'a dyn Pulse, execution: Execution, parts: &[PhaseSpec<'_>], ) -> Self

Declare a fixed plan. Rejected plans retain cancellation via untracked children.

pub fn run<T, E>( &mut self, index: usize, work: impl FnOnce(&dyn Pulse) -> Result<T, E>, ) -> Result<T, E>

where E: AsStopReason,

Run one phase at most once. A missing/repeated index is diagnosed and still runs the work through a cancellation-only view.

pub fn run_classified<T, E>( &mut self, index: usize, is_stop: impl FnOnce(&E) -> bool, work: impl FnOnce(&dyn Pulse) -> Result<T, E>, ) -> Result<T, E>

Run with an explicit classifier when the error type cannot implement the borrowed conversion. The original result is returned unchanged.

pub fn skip(&mut self, index: usize)

Explicitly discharge a phase which is unnecessary.

Trait Implementations

impl Complete for Phases<'_>

fn complete_as(self, outcome: Outcome)

Record an explicitly chosen outcome, resolving unfinished observations. Join workers before calling this. Started but uncompleted children are abandoned; untouched children are skipped on success, not run on error.

fn complete<T, E>(self, result: Result<T, E>) -> Result<T, E>

where E: AsStopReason,

Classify the error with AsStopReason, record completion, and return the original result.

fn complete_classified<T, E>( self, result: Result<T, E>, is_stop: impl FnOnce(&E) -> bool, ) -> Result<T, E>

Complete with an explicit classifier, for a foreign error type that Rust’s orphan rules keep from implementing AsStopReason.

fn complete_with<T, E>( self, body: impl FnOnce(&mut Self) -> Result<T, E>, ) -> Result<T, E>

where E: AsStopReason,

Run a multi-step body with this owner, then complete the owner with the body’s result and return that result unchanged.

fn complete_with_classified<T, E>( self, is_stop: impl FnOnce(&E) -> bool, body: impl FnOnce(&mut Self) -> Result<T, E>, ) -> Result<T, E>

complete_with with an explicit classifier, for a foreign error type that cannot implement AsStopReason, such as an error wrapped with its source location.