Struct RunnablePassthrough 

pub struct RunnablePassthrough;

Passes the input through unchanged. Useful in parallel compositions where one branch should preserve the original input.

Implementations

impl RunnablePassthrough

pub fn assign( branches: Vec<(String, BoxRunnable<Value, Value>)>, ) -> RunnableAssign

Create a RunnableAssign that passes input through and merges additional computed keys.

Trait Implementations

impl Clone for RunnablePassthrough

fn clone(&self) -> RunnablePassthrough

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for RunnablePassthrough

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

Formats the value using the given formatter.

impl Default for RunnablePassthrough

fn default() -> RunnablePassthrough

Returns the “default value” for a type.

impl<T> Runnable<T, T> for RunnablePassthrough

where T: Send + Sync + 'static,

fn invoke<'life0, 'life1, 'async_trait>( &'life0 self, input: T, _config: &'life1 RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<T, 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 stream<'a>( &'a self, input: I, config: &'a RunnableConfig, ) -> RunnableOutputStream<'a, O>

where I: 'a,

Stream the output. Default wraps invoke as a single-item stream. Override for true streaming (e.g., token-by-token from an LLM).

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

where Self: Sized + 'static,

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

impl Copy for RunnablePassthrough