Struct TypedDagNode 

pub struct TypedDagNode<I, O, F> { /* private fields */ }

Typed adapter for a DAG node with explicit input and output contracts.

Implementations

impl<I, O, F> TypedDagNode<I, O, F>

pub fn new( id: impl Into<String>, map_inputs: impl Fn(HashMap<String, Value>) -> AppResult<I> + Send + Sync + 'static, execute: F, ) -> Self

Create a typed node from an input mapper and async operation.

Trait Implementations

impl<I, O, F, Fut> DagNode for TypedDagNode<I, O, F>

where I: Send + 'static, O: Serialize + Send + 'static, F: Fn(I, CancellationToken) -> Fut + Send + Sync + 'static, Fut: Future<Output = AppResult<O>> + Send + 'static,

fn id(&self) -> &str

Unique identifier for this node within the DAG.

fn execute( &self, inputs: HashMap<String, Value>, cancel: CancellationToken, ) -> Pin<Box<dyn Future<Output = AppResult<Value>> + Send + '_>>

Execute the node with the collected outputs from upstream dependencies.