Struct RunnableParallel 

pub struct RunnableParallel<I>
where
    I: Send + Sync + Clone + Debug + 'static,
{ /* private fields */ }

A Runnable that runs multiple Runnables in parallel.

Returns a HashMap with the results keyed by the step names.

Implementations

impl<I> RunnableParallel<I>

where I: Send + Sync + Clone + Debug + 'static,

pub fn new() -> Self

Create a new empty RunnableParallel.

pub fn add<R>(self, key: impl Into<String>, runnable: R) -> Self

where R: Runnable<Input = I, Output = Value> + Send + Sync + 'static,

Add a step to the RunnableParallel.

pub fn with_name(self, name: impl Into<String>) -> Self

Set the name of this RunnableParallel.

Trait Implementations

impl<I> Debug for RunnableParallel<I>

where I: Send + Sync + Clone + Debug + 'static,

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

Formats the value using the given formatter.

impl<I> Default for RunnableParallel<I>

where I: Send + Sync + Clone + Debug + 'static,

fn default() -> Self

Returns the “default value” for a type.

impl<I> Runnable for RunnableParallel<I>

where I: Send + Sync + Clone + Debug + 'static,

type Input = I

The input type for this Runnable.

type Output = HashMap<String, Value>

The output type for this Runnable.

fn name(&self) -> Option<String>

Get the optional name of this Runnable.

fn invoke( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> Result<Self::Output>

Transform a single input into an output.

fn ainvoke<'life0, 'async_trait>( &'life0 self, input: Self::Input, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Self::Output>> + Send + 'async_trait>>

where Self: 'static + 'async_trait, 'life0: 'async_trait,

Transform a single input into an output asynchronously.

fn get_name(&self, suffix: Option<&str>, name: Option<&str>) -> String

Get the name of this Runnable.

fn type_name(&self) -> &'static str

Get the type name of this Runnable.

fn batch( &self, inputs: Vec<Self::Input>, config: Option<ConfigOrList>, _return_exceptions: bool, ) -> Vec<Result<Self::Output>>

where Self: 'static,

Transform multiple inputs into outputs in parallel.

fn abatch<'life0, 'async_trait>( &'life0 self, inputs: Vec<Self::Input>, config: Option<ConfigOrList>, _return_exceptions: bool, ) -> Pin<Box<dyn Future<Output = Vec<Result<Self::Output>>> + Send + 'async_trait>>

where Self: 'static + 'async_trait, 'life0: 'async_trait,

Transform multiple inputs into outputs asynchronously.

fn stream( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> BoxStream<'_, Result<Self::Output>>

Stream output from a single input.

fn astream( &self, input: Self::Input, config: Option<RunnableConfig>, ) -> BoxStream<'_, Result<Self::Output>>

where Self: 'static,

Stream output from a single input asynchronously.

fn transform<'a>( &'a self, input: BoxStream<'a, Self::Input>, config: Option<RunnableConfig>, ) -> BoxStream<'a, Result<Self::Output>>

Transform an input stream into an output stream.

fn atransform<'a>( &'a self, input: BoxStream<'a, Self::Input>, config: Option<RunnableConfig>, ) -> BoxStream<'a, Result<Self::Output>>

where Self: 'static,

Transform an input stream into an output stream asynchronously.

fn bind(self, kwargs: HashMap<String, Value>) -> RunnableBinding<Self>

where Self: Sized,

Bind arguments to this Runnable, returning a new Runnable.

fn with_config(self, config: RunnableConfig) -> RunnableBinding<Self>

where Self: Sized,

Bind config to this Runnable, returning a new Runnable.

fn with_retry( self, max_attempts: usize, wait_exponential_jitter: bool, ) -> RunnableRetry<Self>

where Self: Sized,

Create a new Runnable that retries on failure.

fn map(self) -> RunnableEach<Self>

where Self: Sized,

Return a new Runnable that maps a list of inputs to a list of outputs.