Struct RunnablePassthrough 

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

A Runnable that passes its input through unchanged.

Example

let passthrough = RunnablePassthrough::<i32>::new();
let result = passthrough.invoke(42, None).await?; // 42

Implementations

impl<I: Send + Sync + 'static> RunnablePassthrough<I>

pub fn new() -> Self

Create a new passthrough runnable.

Trait Implementations

impl<I: Clone + Send + Sync + 'static> Clone for RunnablePassthrough<I>

fn clone(&self) -> Self

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<I: Send + Sync + 'static> Debug for RunnablePassthrough<I>

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

Formats the value using the given formatter.

impl<I: Send + Sync + 'static> Default for RunnablePassthrough<I>

fn default() -> Self

Returns the “default value” for a type.

impl<I: Clone + Send + Sync + 'static> Runnable<I, I> for RunnablePassthrough<I>

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

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

Passthrough supports true streaming: each input item is forwarded immediately without buffering.

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<I, LcelError>> + Send>>, LcelError>> + Send + 'async_trait>>

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

Passthrough supports true transform: each item in the input stream is forwarded immediately.

type Error = LcelError

Error type.

fn invoke<'life0, 'async_trait>( &'life0 self, input: I, _config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<I, 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<Input>, config: Option<RunnableConfig>, ) -> Pin<Box<dyn Future<Output = Result<Vec<Output>, Self::Error>> + Send + 'async_trait>>

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

Batch processing - transforms multiple inputs to outputs.