Trait DagNode 

pub trait DagNode: Send + Sync {
    // Required method
    fn process<'a>(
        &'a self,
        ctx: &'a mut DagContext,
    ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>;
}

A processing node in a Dag.

Unlike GraphNode, a DagNode has no routing control — traversal is determined entirely by the declared edge topology. The node simply reads from and writes to the shared DagContext.

Required Methods

fn process<'a>( &'a self, ctx: &'a mut DagContext, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'a>>

Processes the context. The future must be Send.

Implementors

impl DagNode for AgentDagNode

impl DagNode for FnDagNode