Struct RunnableLambda 

pub struct RunnableLambda { /* private fields */ }

A runnable that wraps an async closure.

Example

let double = RunnableLambda::new(|v: Value| {
    Box::pin(async move {
        let n = v.as_i64().unwrap_or(0) * 2;
        Ok(Value::from(n))
    })
});

Implementations

impl RunnableLambda

pub fn new<F>(func: F) -> Self

where F: Fn(Value) -> BoxFuture<'static, Result<Value, SynwireError>> + Send + Sync + 'static,

Create a new lambda runnable from an async closure.

pub fn with_name(self, name: impl Into<String>) -> Self

Set a custom name for this lambda.

Trait Implementations

impl RunnableCore for RunnableLambda

fn invoke<'a>( &'a self, input: Value, _config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Value, SynwireError>>

Invoke the runnable with a single input.

fn name(&self) -> &str

Get the runnable’s name for debugging.

fn batch<'a>( &'a self, inputs: Vec<Value>, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<Vec<Value>, SynwireError>>

Invoke on multiple inputs. Default implementation calls invoke sequentially for each input.

fn stream<'a>( &'a self, input: Value, config: Option<&'a RunnableConfig>, ) -> BoxFuture<'a, Result<BoxStream<'a, Result<Value, SynwireError>>, SynwireError>>

Stream results. Default implementation wraps invoke as a single-item stream.