Struct RunnableSequence 

pub struct RunnableSequence<I, M, O>
where
    I: Send + 'static,
    M: Send + 'static,
    O: Send + 'static,
{ /* private fields */ }

Chains two runnables: output of first feeds into second. Created automatically via the | operator on BoxRunnable.

Trait Implementations

impl<I, M, O> Runnable<I, O> for RunnableSequence<I, M, O>

where I: Send + 'static, M: Send + 'static, O: Send + 'static,

fn stream<'a>( &'a self, input: I, config: &'a RunnableConfig, ) -> RunnableOutputStream<'a, O>

where I: 'a,

Stream: invoke first step fully, then stream the second step. This matches LangChain behavior where only the final component truly streams.

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: I, config: &'life1 RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<O, SynapseError>> + Send + 'async_trait>>

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

Execute this runnable on a single input.

fn batch<'life0, 'life1, 'async_trait>( &'life0 self, inputs: Vec<I>, config: &'life1 RunnableConfig, ) -> Pin<Box<dyn Future<Output = Vec<Result<O, SynapseError>>> + Send + 'async_trait>>

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

Execute this runnable on multiple inputs sequentially.

fn boxed(self) -> BoxRunnable<I, O>

where Self: Sized + 'static,

Wrap this runnable into a type-erased BoxRunnable for composition via |.