Struct RunnableParallel 

pub struct RunnableParallel { /* private fields */ }

Executes named runnables concurrently and collects results as a JSON object.

Each step receives a clone of the input. Results are collected into a serde_json::Value::Object keyed by the step names.

Example

let par = RunnableParallel::new(vec![
    ("a".into(), Box::new(RunnablePassthrough) as Box<dyn RunnableCore>),
    ("b".into(), Box::new(RunnablePassthrough) as Box<dyn RunnableCore>),
]);

Implementations

impl RunnableParallel

pub fn new(steps: Vec<(String, Box<dyn RunnableCore>)>) -> Self

Create from named steps.

Trait Implementations

impl RunnableCore for RunnableParallel

fn invoke<'a>( &'a self, input: Value, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Value, SynwireError>>

Invoke the runnable with a single input.

fn name(&self) -> &str

Get the runnable’s name for debugging.

fn batch<'a>( &'a self, inputs: Vec<Value>, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Vec<Value>, SynwireError>>

Invoke on multiple inputs. Default implementation calls invoke sequentially for each input.

fn stream<'a>( &'a self, input: Value, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<BoxStream<'a, Result<Value, SynwireError>>, SynwireError>>

Stream results. Default implementation wraps invoke as a single-item stream.