Struct Command 

pub struct Command<S: State> {
    pub update: Option<S::Update>,
    pub goto: Goto,
    pub graph: GraphTarget,
    pub resume: Option<ResumeValue>,
    pub stream_data: Vec<Value>,
}

Command: node return value combining state update and routing

Nodes can return S::Update (simple case) or Command<S> (for routing control).

Fields

update: Option<S::Update>

State update to apply

goto: Goto

Routing instruction

graph: GraphTarget

Target graph (current or parent)

resume: Option<ResumeValue>

Resume value for HITL interrupt resumption

When provided, this value is used to resume from a previously triggered interrupt. Supports single values, ID-based mapping, and namespace-based mapping via ResumeValue.

stream_data: Vec<Value>

Custom streaming data to emit during execution

Nodes can attach arbitrary JSON values here that will be emitted as [StreamEvent::Custom] events during graph execution. Each entry in the vector produces one custom stream event tagged with the emitting node name. Use Command::with_stream_data to append items.

Implementations

impl<S: State> Command<S>

pub const fn update(update: S::Update) -> Self

Create command with only state update

pub fn goto(target: impl Into<String>) -> Self

Create command with only routing

pub fn update_and_goto(update: S::Update, target: impl Into<String>) -> Self

Create command with update and routing

pub const fn send(targets: Vec<SendTarget>) -> Self

Create command with dynamic fan-out

pub const fn update_and_send( update: S::Update, targets: Vec<SendTarget>, ) -> Self

Create command with update and fan-out

pub const fn end() -> Self

Create command that terminates current path

pub fn goto_parent(target: impl Into<String>) -> Self

Create command that routes to parent graph

pub fn with_resume(self, value: ResumeValue) -> Self

Attach a resume value to this command

pub fn with_stream_data(self, data: Value) -> Self

Attach custom streaming data to this command

The given value is appended to the command’s streaming data list. During graph execution, each entry is emitted as a [StreamEvent::Custom] event, allowing nodes to push custom JSON payloads to the stream consumer alongside state updates and routing.

Examples

use juncture_core::Command;
use serde_json::json;

// In a node returning Command:
Command::end().with_stream_data(json!({"progress": 0.75}));

Trait Implementations

impl<S: Clone + State> Clone for Command<S>

where S::Update: Clone,

fn clone(&self) -> Command<S>

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl<S: Debug + State> Debug for Command<S>

where S::Update: Debug,

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

Formats the value using the given formatter.

impl<S: State> Default for Command<S>

fn default() -> Self

Returns the “default value” for a type.