Struct SequentialFlowBuilder

pub struct SequentialFlowBuilder<Input, Output, Error, NextNodeInput> { /* private fields */ }

Builder for SequentialFlow.

Implementations

impl<Input, Output, Error> SequentialFlowBuilder<Input, Output, Error, Input>

pub fn new() -> Self

Creates new instance of SequentialFlowBuilder.

impl<Input, Output, Error, LastNodeOutput> SequentialFlowBuilder<Input, Output, Error, LastNodeOutput>

where Input: Send + 'static, Output: Send + 'static, Error: Send + 'static,

pub fn add_node<NodeType, NodeInput, NodeOutput_, NodeError>( self, node: NodeType, ) -> SequentialFlowBuilder<Input, Output, Error, NodeOutput_>

where LastNodeOutput: Send + Sync + Into<NodeInput> + 'static, NodeInput: Send + Sync + 'static, NodeOutput_: Send + Sync + 'static, NodeError: Send + Sync + Into<Error> + 'static, NodeType: Node<NodeInput, NodeOutput<NodeOutput_>, NodeError> + Clone + Send + Sync + 'static,

Adds node to the sequence.

impl<Input, Output, Error, LastNodeOutput> SequentialFlowBuilder<Input, Output, Error, LastNodeOutput>

where Output: Send + Sync + 'static, LastNodeOutput: Into<Output> + Send + Sync + 'static,

pub fn build(self) -> SequentialFlow<Input, Output, Error>

Finalizes the sequence so nodes can’t be added to it.

Trait Implementations

impl<Input, Output, Error> Default for SequentialFlowBuilder<Input, Output, Error, Input>

fn default() -> Self

Returns the “default value” for a type.