Struct anchor_chain::chain::StatefulLinkedChainBuilder

pub struct StatefulLinkedChainBuilder<I, L, K, V> { /* private fields */ }

A builder for constructing a Chain of nodes using Link and StatefulLink.

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

Implementations

impl<I, L, K, V> StatefulLinkedChainBuilder<I, L, K, V>

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

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

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>( 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, StatefulLink<L, N, K, V>: Node<Input = I>,

Adds a new StatefulNode to the chain, linking it to the previous node. Each stateful node will be passed an instance of the StateManager.

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.