Struct MulticastSegment 

pub struct MulticastSegment {
    pub branches: Vec<OutcomeSegment>,
    pub parallel: bool,
    pub parallel_limit: Option<usize>,
    pub stop_on_exception: bool,
    pub timeout: Option<Duration>,
    pub aggregator: Arc<dyn Fn(Vec<Exchange>) -> Exchange + Send + Sync>,
}

Outcome-aware Multicast segment. Holds N child OutcomeSegments and a strategy (sequential or parallel). Parallel cancellation logic mirrors T13 SplitSegment — lower-the-value CAS records lowest-branch-index that Stopped (spec §5.2.2 line 497); pre-start gate skips not-yet-started branches; in-flight branches run to completion (spec §5.6 line 544: no abrupt abort); JoinSet ensures cancel-safe drop on outer future drop.

Each branch receives its OWN clone of the exchange (Multicast semantics — branches do NOT share body mutations).

Aggregation SKIPPED when any branch Stopped (spec §5.2.2).

Fields

branches: Vec<OutcomeSegment>

parallel: bool

parallel_limit: Option<usize>

Maximum number of concurrent branches in parallel mode (None = unlimited).

stop_on_exception: bool

Whether to stop processing on the first exception.

When true, a Failed outcome from any branch halts processing immediately (sequential) or is propagated after all in-flight branches complete (parallel). When false, failures are collected and processing continues; the last error (last-wins, matching legacy LastWins aggregation) is propagated after all branches complete.

Stopped outcomes always propagate per ADR-0025 §7 regardless of this flag.

timeout: Option<Duration>

Per-branch timeout in parallel mode (None = no timeout).

aggregator: Arc<dyn Fn(Vec<Exchange>) -> Exchange + Send + Sync>

Trait Implementations

impl Clone for MulticastSegment

fn clone(&self) -> MulticastSegment

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl OutcomePipeline for MulticastSegment

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.