Struct SubgraphNode 

pub struct SubgraphNode<S: State, Sub: State> {
    pub subgraph: Arc<CompiledGraph<Sub>>,
    pub name: String,
    pub input_map: Arc<dyn Fn(&S) -> Sub + Send + Sync>,
    pub output_map: Arc<dyn Fn(&Sub) -> S::Update + Send + Sync>,
    pub config: SubgraphConfig,
}

Subgraph node wrapper for type erasure

When a subgraph has a different state type than its parent graph, this wrapper handles the state transformation via input_map and output_map.

Send API Compatibility

The Send API (dynamic fan-out) works correctly with subgraph nodes. When multiple Send operations target the same subgraph node, each invocation receives a unique checkpoint namespace (|name:uuid) ensuring proper state isolation between concurrent subgraph executions. This uniqueness is guaranteed by SubgraphPersistence::Inherit mode, which generates a fresh UUID on every call to [compute_child_namespace].

Fields

subgraph: Arc<CompiledGraph<Sub>>

Compiled subgraph to execute

name: String

Subgraph name for logging

input_map: Arc<dyn Fn(&S) -> Sub + Send + Sync>

Transform parent state to subgraph input

output_map: Arc<dyn Fn(&Sub) -> S::Update + Send + Sync>

Transform subgraph output to parent state update

config: SubgraphConfig

Subgraph configuration

Implementations

impl<S: State, Sub: State> SubgraphNode<S, Sub>

pub fn new( subgraph: Arc<CompiledGraph<Sub>>, name: String, input_map: Arc<dyn Fn(&S) -> Sub + Send + Sync>, output_map: Arc<dyn Fn(&Sub) -> S::Update + Send + Sync>, config: SubgraphConfig, ) -> Self

Create a new subgraph node

Trait Implementations

impl<S: State, Sub: State> Debug for SubgraphNode<S, Sub>

fn fmt(&self, f: &mut Formatter<'_>) -> Result

Formats the value using the given formatter.

impl<S: State, Sub> Node<S> for SubgraphNode<S, Sub>

where Sub: State + Serialize + for<'de> Deserialize<'de>, Sub::Update: Serialize,

fn call( &self, state: &S, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute the node logic

fn name(&self) -> &str

Get the node name

fn call_arc( &self, state: Arc<S>, config: &RunnableConfig, ) -> Pin<Box<dyn Future<Output = Result<Command<S>, JunctureError>> + Send + '_>>

Execute node logic with Arc<S> to avoid O(N) state clone.