Struct RunnableCallable 

pub struct RunnableCallable { /* private fields */ }

Wraps a function as a Runnable.

This is the Rust equivalent of Python’s RunnableCallable. Functions always receive (JsonValue, RunnableConfig) — the caller is responsible for marshalling state into JsonValue.

Implementations

impl RunnableCallable

pub fn new<F, Fut>(name: impl Into<String>, f: F) -> Self

where F: Fn(JsonValue, RunnableConfig) -> Fut + Send + Sync + 'static, Fut: Future<Output = Result<JsonValue, RunnableError>> + Send + 'static,

Create from an async function.

pub fn new_sync<F>(name: impl Into<String>, f: F) -> Self

where F: Fn(&JsonValue, &RunnableConfig) -> Result<JsonValue, RunnableError> + Send + Sync + 'static,

Create from a sync function (wrapped as async).

Trait Implementations

impl Runnable for RunnableCallable

fn invoke( &self, input: &JsonValue, config: &RunnableConfig, ) -> Result<JsonValue, RunnableError>

Execute synchronously.

fn ainvoke<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, input: &'life1 JsonValue, config: &'life2 RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<JsonValue, RunnableError>> + Send + 'async_trait>>

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

Execute asynchronously.

fn name(&self) -> &str

Human-readable name for tracing/debugging.