Struct SubgraphNode 

pub struct SubgraphNode<S: StateSchema, SubS: StateSchema> { /* private fields */ }

Subgraph Node - A node that executes a nested compiled graph

This allows composition of graphs by embedding one graph inside another. The subgraph receives mapped input state and returns mapped output state.

Implementations

impl<S: StateSchema, SubS: StateSchema> SubgraphNode<S, SubS>

pub fn new( name: impl Into<String>, subgraph: CompiledGraph<SubS>, input_mapper: impl Fn(&S) -> SubS + Send + Sync + 'static, output_mapper: impl Fn(&SubS, &mut S) + Send + Sync + 'static, ) -> Self

Create a new subgraph node with the given name, subgraph, and mappers.

impl<S: StateSchema + Clone> SubgraphNode<S, S>

pub fn same_state(name: impl Into<String>, subgraph: CompiledGraph<S>) -> Self

Create a subgraph node sharing the same state type, using clone-based mappers.

Trait Implementations

impl<S: StateSchema + 'static, SubS: StateSchema + 'static> GraphNode<S> for SubgraphNode<S, SubS>

fn execute<'life0, 'life1, 'async_trait>( &'life0 self, state: &'life1 S, _config: Option<NodeConfig>, ) -> Pin<Box<dyn Future<Output = NodeResult<S>> + Send + 'async_trait>>

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

Execute the node

fn name(&self) -> &str

Get node name