Struct FilterSegment 

pub struct FilterSegment {
    pub predicate: FilterPredicate,
    pub body: OutcomeSegment,
}

Outcome-aware structural EIP segment for the Filter pattern.

When the predicate passes, delegates to body (which can return Completed, Stopped, or Failed). When the predicate fails, returns Completed(original_exchange) — the exchange is returned as-is and the body is skipped entirely.

Unlike FilterService (which operates at the Tower layer and cannot preserve Stopped(ex) with mutations), FilterSegment operates at the PipelineOutcome layer and preserves the exchange at the Stop point including all mutations.

Fields

predicate: FilterPredicate

body: OutcomeSegment

Trait Implementations

impl Clone for FilterSegment

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 FilterSegment

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.