Struct FanOutTransition 

pub struct FanOutTransition { /* private fields */ }

A typed fan-out transition builder that must be connected to a join before it can run.

Build one with Transition::fan_out and add additional branch targets with FanOutTransition::and. Each branch input is type-checked before the branch target is erased for runtime scheduling.

Fan-out always represents a joined branch group. True unjoined fan-out with multiple independent task endings is not supported; model that shape by sending each branch to a join node and finishing from the join node.

Implementations

impl FanOutTransition

pub fn and<T, Input>(self, node_id: &NodeId<T>, context: Input) -> Self

where T: TaskNode + ?Sized, Input: Into<T::Input>,

Adds another typed branch target to this fan-out.

The branch input must convert into the target node’s input type.

pub fn join_with<J>(self, join_target: J) -> Transition

where J: JoinDestination,

Attaches every branch from this fan-out to the provided join target.

This defines the branch group and the join node that waits for every branch in that group. Each branch still needs its own registered transition to the same join target when it is ready to contribute its output. If branches are conceptually terminal, register each branch to transition to this join target and finish from the join node.

pub fn concurrency_model(self, concurrency_model: ConcurrencyModel) -> Self

Overrides the concurrency model for work scheduled by this fan-out.

Trait Implementations

impl Debug for FanOutTransition

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

Formats the value using the given formatter.