pub struct Lambda<I, O> { /* private fields */ }Expand description
Wraps an async or sync closure so it can act as a Runnable<I, O>.
Implementations§
Source§impl<I, O> Lambda<I, O>
impl<I, O> Lambda<I, O>
Sourcepub fn from_async<F, Fut>(f: F) -> Self
pub fn from_async<F, Fut>(f: F) -> Self
Build from an async closure that ignores the config.
Sourcepub fn from_async_with_config<F, Fut>(f: F) -> Self
pub fn from_async_with_config<F, Fut>(f: F) -> Self
Build from an async closure that uses the config.
Trait Implementations§
Source§impl<I, O> Runnable<I, O> for Lambda<I, O>
impl<I, O> Runnable<I, O> for Lambda<I, O>
Source§fn invoke<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<O>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
fn invoke<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<O>> + Send + 'async_trait>>where
Self: 'async_trait,
'life0: 'async_trait,
One-shot invocation. The hot path.
Source§fn batch<'life0, 'async_trait>(
&'life0 self,
inputs: Vec<I>,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>
fn batch<'life0, 'async_trait>( &'life0 self, inputs: Vec<I>, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Vec<O>>> + Send + 'async_trait>>
Run multiple inputs in parallel. Defaults to
buffer_unordered
honouring config.max_concurrency.Source§fn stream<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>>> + Send + 'async_trait>>
fn stream<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<RunnableStream<O>>> + Send + 'async_trait>>
Stream the final output (chunks of
O). Default emits one item via
invoke — non-streaming runnables are correct without override.Source§fn stream_events<'life0, 'async_trait>(
&'life0 self,
input: I,
config: RunnableConfig,
) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>
fn stream_events<'life0, 'async_trait>( &'life0 self, input: I, config: RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<EventStream>> + Send + 'async_trait>>
Stream structured events. Default emits OnStart + OnEnd around an
invoke call. Graph engines override to surface per-node events.Source§fn input_schema(&self) -> Option<Value>
fn input_schema(&self) -> Option<Value>
JSON Schema for the input type, if known.
Source§fn output_schema(&self) -> Option<Value>
fn output_schema(&self) -> Option<Value>
JSON Schema for the output type, if known.
Auto Trait Implementations§
impl<I, O> Freeze for Lambda<I, O>
impl<I, O> !RefUnwindSafe for Lambda<I, O>
impl<I, O> Send for Lambda<I, O>
impl<I, O> Sync for Lambda<I, O>
impl<I, O> Unpin for Lambda<I, O>
impl<I, O> UnsafeUnpin for Lambda<I, O>
impl<I, O> !UnwindSafe for Lambda<I, O>
Blanket Implementations§
Source§impl<T> BorrowMut<T> for Twhere
T: ?Sized,
impl<T> BorrowMut<T> for Twhere
T: ?Sized,
Source§fn borrow_mut(&mut self) -> &mut T
fn borrow_mut(&mut self) -> &mut T
Mutably borrows from an owned value. Read more
Source§impl<T> CloneToUninit for Twhere
T: Clone,
impl<T> CloneToUninit for Twhere
T: Clone,
Source§impl<T> Instrument for T
impl<T> Instrument for T
Source§fn instrument(self, span: Span) -> Instrumented<Self>
fn instrument(self, span: Span) -> Instrumented<Self>
Source§fn in_current_span(self) -> Instrumented<Self>
fn in_current_span(self) -> Instrumented<Self>
Source§impl<R, I, O> RunnableExt<I, O> for R
impl<R, I, O> RunnableExt<I, O> for R
Source§fn pipe<R2, O2>(self, next: R2) -> Pipe<Self, R2, I, O, O2>
fn pipe<R2, O2>(self, next: R2) -> Pipe<Self, R2, I, O, O2>
Pipe this runnable into another, building a
Pipe<Self, Next>.Source§fn with_retry(self, policy: RetryPolicy) -> Retry<Self, I, O>where
I: Clone,
fn with_retry(self, policy: RetryPolicy) -> Retry<Self, I, O>where
I: Clone,
Wrap with a retry policy.
Source§fn with_max_retries(self, attempts: u32) -> Retry<Self, I, O>where
I: Clone,
fn with_max_retries(self, attempts: u32) -> Retry<Self, I, O>where
I: Clone,
Shortcut: retry with default policy and N attempts.
Source§fn with_timeout(self, duration: Duration) -> Timeout<Self, I, O>
fn with_timeout(self, duration: Duration) -> Timeout<Self, I, O>
Wrap with a per-call timeout.
Source§fn with_fallback<F>(self, fallback: F) -> Fallback<Self, F, I, O>
fn with_fallback<F>(self, fallback: F) -> Fallback<Self, F, I, O>
Wrap with a fallback runnable.
Source§fn with_memory_cache<K, F>(
self,
key_fn: F,
) -> Cache<Self, I, O, K, MemoryCache<K, O>>
fn with_memory_cache<K, F>( self, key_fn: F, ) -> Cache<Self, I, O, K, MemoryCache<K, O>>
Wrap with an in-memory cache keyed by
key_fn(&I).