Struct AsyncBatchFlow 

pub struct AsyncBatchFlow { /* private fields */ }

Implementations

impl AsyncBatchFlow

pub fn new() -> Self

pub fn start(self, node: AsyncNode) -> Self

pub fn set_params(&mut self, params: Params)

pub async fn run_batch( &self, shared: &mut (dyn Any + Send), batch_params: Vec<Params>, ) -> Result<Vec<()>>

Trait Implementations

impl Clone for AsyncBatchFlow

fn clone(&self) -> AsyncBatchFlow

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for AsyncBatchFlow

fn default() -> Self

Returns the “default value” for a type.