Struct RunnableParallel 

pub struct RunnableParallel<Input, Output> { /* private fields */ }

Implementations

impl<Input, Output> RunnableParallel<Input, Output>

pub fn new( steps: BTreeMap<String, Arc<dyn Runnable<Input, Output> + Send + Sync>>, ) -> Self

Trait Implementations

impl<Input, Output> Runnable<Input, BTreeMap<String, Output>> for RunnableParallel<Input, Output>

where Input: Clone + Send + Sync + 'static, Output: Send + Sync + 'static,

fn invoke<'life0, 'async_trait>( &'life0 self, input: Input, ) -> Pin<Box<dyn Future<Output = Result<BTreeMap<String, Output>, WesichainError>> + Send + 'async_trait>>

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

fn stream<'a>( &'a self, input: Input, ) -> BoxStream<'a, Result<StreamEvent, WesichainError>>

fn to_serializable(&self) -> Option<SerializableRunnable>

fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Input>, ) -> Pin<Box<dyn Future<Output = Vec<Result<Output, WesichainError>>> + Send + 'async_trait>>

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