Struct ChannelState 

pub struct ChannelState { /* private fields */ }

A concrete graph State wrapping a ChannelSet.

ChannelState implements crate::graph::StateReducer<ChannelState, ChannelUpdate> for itself, so a channel-based graph is built directly with GraphBuilder<ChannelState, ChannelUpdate> and runs on the unchanged executor: each superstep the executor folds every branch’s ChannelUpdate into the committed ChannelState through this reducer, dispatching each write to its channel’s merge rule.

The reducer’s &self receiver is unused — the merge rules travel inside the running state’s ChannelSet — so any ChannelState value (for example ChannelState::default) can be passed to set_reducer.

Implementations

impl ChannelState

pub fn new() -> Self

Creates a state with no channels.

pub fn with_channel( self, name: impl Into<String>, channel: impl Channel + 'static, ) -> Self

Registers channel under name, returning the state for chaining. Use this to declare a graph’s channel schema before running.

pub fn channels(&self) -> &ChannelSet

Borrows the underlying ChannelSet.

pub fn get(&self, name: &str) -> Option<&Value>

Returns the current value of channel name, if written.

pub fn snapshot(&self) -> BTreeMap<String, Value>

Returns the tracked channel values (see ChannelSet::snapshot).

pub fn is_ready(&self, name: &str) -> Result<bool>

Whether channel name is a satisfied barrier (see ChannelSet::is_ready).

pub fn merge(self, update: ChannelUpdate) -> Result<Self>

Folds a ChannelUpdate into this state, dispatching each write to its channel’s merge rule. This is the core reducer step.

When the update is stamped (via ChannelUpdate::at_step) with a step number that differs from the last one seen, the per-step write tracking is reset and Ephemeral channels are cleared before the writes apply. A second write to a non-aggregate channel within the same stamped step raises TinyAgentsError::InvalidConcurrentUpdate.

Trait Implementations

impl Clone for ChannelState

fn clone(&self) -> ChannelState

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for ChannelState

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

Formats the value using the given formatter.

impl Default for ChannelState

fn default() -> ChannelState

Returns the “default value” for a type.

impl StateReducer<ChannelState, ChannelUpdate> for ChannelState

ChannelState is its own StateReducer: the &self receiver is unused (merge rules live in the running state’s ChannelSet), so any ChannelState may be passed to set_reducer.

fn apply( &self, state: ChannelState, update: ChannelUpdate, ) -> Result<ChannelState>

Applies update to state, producing the new state.