Struct RunnableSequence

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

A runnable sequence that chains multiple runnables together

Implementations

impl<Input, Intermediate, Output> RunnableSequence<Input, Intermediate, Output>

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

pub fn new( first: Arc<dyn Runnable<Input, Intermediate>>, second: Arc<dyn Runnable<Intermediate, Output>>, ) -> Self

Create a new runnable sequence

Trait Implementations

impl<Input, Intermediate, Output> Runnable<Input, Output> for RunnableSequence<Input, Intermediate, Output>

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

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

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

Invoke the runnable with a single input

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

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

Invoke the runnable with a single input (convenience method with default config)

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

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

Batch invoke the runnable with multiple inputs

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

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

Stream the output of the runnable

fn input_schema(&self) -> Option<Value>

Get the input schema for this runnable

fn output_schema(&self) -> Option<Value>

Get the output schema for this runnable

fn config_schema(&self) -> Option<Value>

Get the configuration schema for this runnable