Struct RunnableSequence 

pub struct RunnableSequence { /* private fields */ }

A sequence of runnables executed one after another.

The output of each step becomes the input to the next.

Example

let seq = RunnableSequence::new(vec![
    Box::new(RunnablePassthrough),
    Box::new(RunnablePassthrough),
]);

Implementations

impl RunnableSequence

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

Create a new sequence from an ordered list of steps.

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

Set a custom name for this sequence.

Trait Implementations

impl RunnableCore for RunnableSequence

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.