Struct Builder 

pub struct Builder<Input, Output, Error, Context, NodeTypes = (), NodeIOETypes = ()>
where
    Input: Send + Clone,
    Error: Send,
    Context: Fork + Join + Send,
{ /* private fields */ }

Builder for ParallelFlow.

This builder ensures:

• Input into the flow can be converted into the input of all nodes
• error of all nodes can be converted into the Error of the flow
• Joiner returns Result<Output, Error>

See also ParallelFlow.

Implementations

impl<Input, Output, Error, Context> Builder<Input, Output, Error, Context>

where Input: Send + Clone, Error: Send, Context: Fork + Join + Send,

pub fn new() -> Self

Creates a new empty builder for ParallelFlow.

pub fn add_node<NodeType, NodeInput, NodeOutput, NodeError>( self, node: NodeType, ) -> Builder<Input, Output, Error, Context, (NodeType,), ((), (NodeInput, NodeOutput<NodeOutput>, NodeError))>

where Input: Into<NodeInput>, NodeError: Into<Error>, NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError, Context> + Send + Sync + Clone, NodeOutput: Send,

Adds a new node.

The new node must satisfy:

• Self: Node<NodeInputType, NodeOutput<NodeOutputType>, NodeErrorType, _>
• Input: Into<NodeInputType>,
• NodeErrorType: Into<Error>,

Returns

A new Builder with the added node.

impl<Input, Output, Error, Context, NodeTypes, OtherNodeIOETypes, LastNodeIOETypes> Builder<Input, Output, Error, Context, NodeTypes, (OtherNodeIOETypes, LastNodeIOETypes)>

where Input: Send + Clone, Error: Send, Context: Fork + Join + Send,

pub fn add_node<NodeType, NodeInput, NodeOutput, NodeError>( self, node: NodeType, ) -> Builder<Input, Output, Error, Context, (NodeTypes, NodeType), ((OtherNodeIOETypes, LastNodeIOETypes), (NodeInput, NodeOutput<NodeOutput>, NodeError))>

where Input: Into<NodeInput>, NodeError: Into<Error>, NodeType: Node<NodeInput, NodeOutputStruct<NodeOutput>, NodeError, Context> + Send + Sync + Clone, NodeOutput: Send,

Adds a new node.

The new node must satisfy:

• Self: Node<NodeInputType, NodeOutput<NodeOutputType>, NodeErrorType, _>
• Input: Into<NodeInputType>,
• NodeErrorType: Into<Error>,

Returns

A new Builder with the added node.

pub fn build<J, ChainRunOutput>( self, joiner: J, ) -> Flow<Input, Output, Error, Context, ChainRunOutput, J, NodeTypes, (OtherNodeIOETypes, LastNodeIOETypes)>

where for<'a> J: Joiner<'a, ChainRunOutput, Output, Error, Context>, NodeTypes: ChainRun<Input, Result<ChainRunOutput, Error>, Context, (OtherNodeIOETypes, LastNodeIOETypes)>,

Finalizes the builder and produces a ParallelFlow instance.

The joiner must satisfy:

• Self: Joiner<'_, NodesOutputs, Output, Error, _>

When using closure as a joiner it always needs:

• to be an async closure - because of lifetimes
• for context to:
  • have the type of a context specified when using context - because it cannot infer the type
    or
  • have the context specified as _: &mut _ when not using context - because it cannot satisfy that Joiner is implemented

Examples

// ...
.build(async |_, _: &mut _| {
    Ok(NodeOutput::Ok(120))
});
// ...
.build(async |_, ctx: &mut Context| {
    let _forked_ctx = ctx.fork();
    Ok(NodeOutput::Ok(120))
});

Trait Implementations

impl<Input, Output, Error, Context, NodeTypes, NodeIOETypes> Debug for Builder<Input, Output, Error, Context, NodeTypes, NodeIOETypes>

where NodeTypes: ChainDebug, Input: Send + Clone, Error: Send, Context: Fork + Join + Send,

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

Formats the value using the given formatter.

impl<Input, Output, Error, Context> Default for Builder<Input, Output, Error, Context>

where Input: Send + Clone, Error: Send, Context: Fork + Join + Send,

fn default() -> Self

Returns the “default value” for a type.