Struct LoopSegment 

pub struct LoopSegment {
    pub config: LoopConfig,
    pub body: OutcomeSegment,
}

Outcome-aware structural EIP segment for the Loop pattern.

Operates at the PipelineOutcome layer so that Stopped(ex) from a sub-step (e.g. Stop EIP) is preserved with the exchange including all mutations. Supports both Count and While modes, mirroring LoopService semantics exactly.

Unlike LoopService (which operates at the Tower layer), LoopSegment correctly short-circuits on PipelineOutcome::Stopped or Failed.

Fields

config: LoopConfig

body: OutcomeSegment

Trait Implementations

impl Clone for LoopSegment

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl OutcomePipeline for LoopSegment

fn clone_box(&self) -> Box<dyn OutcomePipeline>

Clone the segment into a new boxed instance. Required because Box<dyn OutcomePipeline> cannot directly derive Clone.

fn run<'a>( &'a mut self, exchange: Exchange, ) -> Pin<Box<dyn Future<Output = PipelineOutcome> + Send + 'a>>

Execute the segment against exchange, returning a PipelineOutcome.