Struct RunnableLambda 

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

Runnable<I, O> backed by a user-supplied async closure.

The closure receives the input and an owned ExecutionContext (cheaply Clone). It must return a future that is Send + 'static — common in practice when the closure body uses owned data and tokio primitives.

Implementations

impl<I, O> RunnableLambda<I, O>

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

pub fn new<F, Fut>(f: F) -> RunnableLambda<I, O>

where F: Fn(I, ExecutionContext) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<O, Error>> + Send + 'static,

Wrap an async closure into a Runnable.

let double = RunnableLambda::new(|x: i32, _ctx| async move { Ok(x * 2) });

Trait Implementations

impl<I, O> Clone for RunnableLambda<I, O>

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

fn clone(&self) -> RunnableLambda<I, O>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<I, O> Runnable<I, O> for RunnableLambda<I, O>

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

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

where 'life0: 'async_trait, 'life1: 'async_trait, RunnableLambda<I, O>: 'async_trait,

Single-shot invocation.

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

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

Batch invocation. The default runs invoke sequentially over the input vector. Implementors that can parallelize (e.g. independent provider calls) override this.

fn stream<'life0, 'life1, 'async_trait>( &'life0 self, input: I, mode: StreamMode, ctx: &'life1 ExecutionContext, ) -> Pin<Box<dyn Future<Output = Result<Pin<Box<dyn Stream<Item = Result<StreamChunk<O>, Error>> + Send + 'life0>>, Error>> + Send + 'async_trait>>

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

Streaming invocation, shaped by mode (see StreamMode).

fn name(&self) -> Cow<'_, str>

Human-readable identifier used by tracing and debug output. Default is the Rust type name — implementors may override with a domain label (e.g. "anthropic-messages", "json-parser").