Struct BatchFlow

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

BatchFlow provides parallel processing of items from a context

Implementations

impl<Context, ItemType, A> BatchFlow<Context, ItemType, A>

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

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

Create a new batch flow with the given item workflow

pub async fn execute( &self, ctx: &mut Context, ) -> Result<Vec<Result<ItemType, FloxideError>>, WorkflowError>

Execute the batch flow with the given context

Trait Implementations

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

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

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

Formats the value using the given formatter.