Struct OutcomeSegment 

pub struct OutcomeSegment { /* private fields */ }

Wrapper around Box<dyn OutcomePipeline>. Constructed via OutcomeSegment::new(...) and run via run(exchange).

Implementations

impl OutcomeSegment

pub fn new(inner: Box<dyn OutcomePipeline>) -> Self

pub async fn run(&mut self, exchange: Exchange) -> PipelineOutcome

Trait Implementations

impl Clone for OutcomeSegment

fn clone(&self) -> OutcomeSegment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for OutcomeSegment

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl OutcomePipeline for OutcomeSegment

OutcomeSegment implements OutcomePipeline by delegating to its inner Box<dyn OutcomePipeline>. CompiledStep::Segment can now produce segment directly as Box<dyn OutcomePipeline>.

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.

impl RetryableStep for OutcomeSegment

OutcomeSegment implements RetryableStep so it can participate in the retry path alongside BoxProcessor. Lives in camel-api (where both OutcomeSegment and RetryableStep are defined).

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