Struct SyncNodeFn 

pub struct SyncNodeFn<F>(pub F);

Wrapper for sync node functions.

Use this to pass sync closures to add_node:

graph.add_node("my_node", SyncNodeFn(|input, _config| {
    Ok(json!({"result": 42}))
}));

Tuple Fields

0: F

Trait Implementations

impl<F> IntoNodeFunction for SyncNodeFn<F>

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

fn into_runnable(self, name: &str) -> Arc<dyn Runnable>