Struct JoinNode 

pub struct JoinNode { /* private fields */ }

A node that merges results from parallel branches.

After fan-out, parallel branches write their results to known state keys. The JoinNode reads those keys, applies a merge function, and writes the merged result to an output key.

Implementations

impl JoinNode

pub fn new( input_keys: Vec<String>, output_key: impl Into<String>, merge_fn: impl Fn(Vec<(String, Value)>) -> Result<Value> + Send + Sync + 'static, ) -> Self

Create a new JoinNode.

• input_keys: state keys to collect from parallel branches.
• output_key: state key to write the merged result to.
• merge_fn: function that merges the collected values.

pub fn with_name(self, name: impl Into<String>) -> Self

Set a name for this node.

pub fn collect_array( input_keys: Vec<String>, output_key: impl Into<String>, ) -> Self

Convenience: create a JoinNode that collects values into an array.

pub fn merge_objects( input_keys: Vec<String>, output_key: impl Into<String>, ) -> Self

Convenience: create a JoinNode that merges objects (shallow).

Trait Implementations

impl Debug for JoinNode

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

Formats the value using the given formatter.

impl Node for JoinNode

fn execute<'life0, 'life1, 'life2, 'async_trait>( &'life0 self, state: &'life1 AgentState, _config: &'life2 GraphConfig, ) -> Pin<Box<dyn Future<Output = Result<NodeOutput>> + Send + 'async_trait>>

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

Execute this node

fn name(&self) -> Option<&str>

Optional: Get a name for this node (for debugging)