Struct SplitNode

pub struct SplitNode<I, O, F>
where
    F: Fn(I) -> Vec<O> + Send + Sync,
{ /* private fields */ }

A node that splits its input into multiple outputs using the provided function.

Given an input I, the splitter function returns Vec<O>, and each element is emitted via a Transition::NextAll to the workflow engine.

Implementations

impl<I, O, F> SplitNode<I, O, F>

where F: Fn(I) -> Vec<O> + Send + Sync,

pub fn new(splitter: F) -> Self

Create a new SplitNode from a function that maps an input to a Vec of outputs.

Trait Implementations

impl<I: Clone, O: Clone, F> Clone for SplitNode<I, O, F>

where F: Fn(I) -> Vec<O> + Send + Sync + Clone,

fn clone(&self) -> SplitNode<I, O, F>

Returns a copy of the value.

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

Performs copy-assignment from source.

impl<I: Debug, O: Debug, F> Debug for SplitNode<I, O, F>

where F: Fn(I) -> Vec<O> + Send + Sync + Debug,

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

Formats the value using the given formatter.

impl<C, I, O, F> Node<C> for SplitNode<I, O, F>

where C: Context, I: Send + Sync + 'static, O: Send + Sync + 'static, F: Fn(I) -> Vec<O> + Send + Sync,

type Input = I

Input type for the split node.

type Output = O

Output type produced by the split node.

fn process<'life0, 'life1, 'async_trait>( &'life0 self, _ctx: &'life1 C, input: I, ) -> Pin<Box<dyn Future<Output = Result<Transition<O>, FloxideError>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Process an input value, producing multiple outputs via NextAll transition.