Struct StepDecision 

pub struct StepDecision { /* private fields */ }

Describes the durable outcome of one successful Step execution.

A decision moves to one or more Steps, completes or fails the Flow, waits for Channels to empty, or deliberately leaves the Flow at a dead end.

Implementations

impl StepDecision

pub fn go_to<TargetStep>(step: &TargetStep, input: TargetStep::Input) -> Self

where TargetStep: Step,

Moves to one typed target Step.

pub fn go_to_many(movements: impl IntoIterator<Item = StepMovement>) -> Self

Moves to all targets, enabling concurrent active Steps.

pub fn graceful_complete<Output: Value>(output: Output) -> Self

Completes only after all other active Steps finish, returning output.

pub fn force_complete<Output: Value>(output: Output) -> Self

Completes immediately, abandoning other active Steps and returning output.

pub fn force_complete_if_channels_empty<Output: Value>( output: Output, fallback: StepMovement, channels: impl IntoIterator<Item = ChannelGuard>, ) -> Self

Completes with output when every guard is empty; otherwise follows fallback.

pub fn force_fail(reason: impl Into<String>) -> Self

Fails the Flow immediately with an application-provided reason.

pub fn dead_end() -> Self

Leaves the Flow running with no next Step.

Use this only when an RPC or external operation will resume the Flow later.