Struct anchor_chain::chain::LinkedChainBuilder

pub struct LinkedChainBuilder<I, L> { /* private fields */ }

A builder for constructing a Chain of nodes using Link.

LinkedChainBuilder takes an initial node and allows for incremental construction of a processing chain, adding nodes one at a time. New nodes are linked to the previous nodes using nested Link instances.

Implementations

impl<I, L> LinkedChainBuilder<I, L>

where L: Node<Input = I> + Send + Sync + Debug, I: Send,

pub fn link<N>(self, next: N) -> LinkedChainBuilder<I, Link<L, N>>

where N: Node<Input = L::Output> + Stateless + Send + Sync + Debug, L::Output: Send, Link<L, N>: Node<Input = I>,

Adds a new node to the chain, linking it to the previous node.

pub fn link_with_state<N, K, V>( self, next: N ) -> StatefulLinkedChainBuilder<I, StatefulLink<L, N, K, V>, K, V>

where N: Node<Input = L::Output> + Stateful<K, V> + Send + Sync + Debug, L::Output: Send, Link<L, N>: Node<Input = I>, K: Eq + Hash + Clone + Send + Debug, V: Clone + Send + Debug,

Adds a new StatefulNode to the chain, linking it to the previous node. A new StateManager will also be created that will be passed to all stateful nodes in the chain.

pub fn build(self) -> Chain<I, L::Output, L>

where L: Node,

Finalizes the construction of the chain, returning a Chain instance ready for processing.