Struct RunnableBinding 

pub struct RunnableBinding<I: Send + Sync + 'static, O: Send + Sync + 'static> { /* private fields */ }

A Runnable that binds runtime parameters and config to an inner runnable.

Example

let chain = llm
    .pipe(parser)
    .bind("stop", json!("\n"))
    .with_config(RunnableConfig::new().with_tag("production"));

Implementations

impl<I: Send + Sync + 'static, O: Send + Sync + 'static> RunnableBinding<I, O>

pub fn new<R>(runnable: R) -> Self

where R: Runnable<I, O> + 'static, R::Error: Into<LcelError>,

Create a new binding wrapping the given runnable.

pub fn bind(self, key: impl Into<String>, value: Value) -> Self

Bind a runtime keyword argument.

The kwargs are merged into the RunnableConfig metadata when the runnable is invoked.

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

Set the execution config.

This config is merged with any config passed at invocation time.

Trait Implementations

impl<I: Send + Sync + 'static, O: Send + Sync + 'static> Debug for RunnableBinding<I, O>

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

Formats the value using the given formatter.

impl<I: Send + Sync + 'static, O: Send + Sync + 'static> Runnable<I, O> for RunnableBinding<I, O>

type Error = LcelError

Error type.

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

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

Transforms single input to output.

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

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

Batch processing - transforms multiple inputs to outputs.

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

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

Streaming output - for real-time responses (LLM, etc).

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

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

Stream-to-stream transformation - the core of LCEL streaming.