Struct BatchNode

pub struct BatchNode<Context, ItemType, A = DefaultAction>
where
    Context: BatchContext<ItemType> + Send + Sync + 'static,
    ItemType: Clone + Send + Sync + 'static,
    A: ActionType + Clone + Send + Sync + 'static,
{ /* private fields */ }

A node that processes a batch of items in parallel

Implementations

impl<Context, ItemType, A> BatchNode<Context, ItemType, A>

where Context: BatchContext<ItemType> + Clone + Send + Sync + 'static, ItemType: Clone + Send + Sync + 'static, A: ActionType + Clone + Send + Sync + 'static,

pub fn new(item_workflow: Workflow<Context, A>, parallelism: usize) -> Self

Create a new batch node with the given item workflow and parallelism

Trait Implementations

impl<Context, ItemType, A> Debug for BatchNode<Context, ItemType, A>

where Context: BatchContext<ItemType> + Send + Sync + 'static, ItemType: Clone + Send + Sync + 'static, A: ActionType + Send + Sync + 'static,

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

Formats the value using the given formatter.

impl<Context, ItemType, A> Node<Context, A> for BatchNode<Context, ItemType, A>

where Context: BatchContext<ItemType> + Clone + Send + Sync + 'static, ItemType: Clone + Send + Sync + 'static, A: ActionType + Default + Debug + Clone + Send + Sync + 'static,

type Output = Vec<Result<ItemType, FloxideError>>

The output type produced by this node

fn id(&self) -> NodeId

Get the unique identifier for this node

fn process<'life0, 'life1, 'async_trait>( &'life0 self, ctx: &'life1 mut Context, ) -> Pin<Box<dyn Future<Output = Result<NodeOutcome<Self::Output, A>, FloxideError>> + Send + 'async_trait>>

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

Process the node asynchronously