Struct Barrier 

pub struct Barrier {
    pub expected: usize,
}

Count-based barrier: accumulates writes into a JSON array and is ready only once it has collected at least expected arrivals. Allows concurrent same-step writes (fan-in is the whole point).

Fields

expected: usize

Number of arrivals required before Channel::is_ready returns true.

Implementations

impl Barrier

pub fn new(expected: usize) -> Self

Creates a count-based barrier that is ready after expected arrivals.

Trait Implementations

impl Channel for Barrier

fn kind(&self) -> &'static str

A short, stable kind tag used for debugging and topology export.

fn merge(&self, current: Option<Value>, incoming: Value) -> Result<Value>

Folds incoming into the channel’s current value, returning the new value. current is None the first time the channel is written.

fn allows_concurrent(&self) -> bool

Whether more than one concurrent branch may write this channel within a single superstep. Aggregates (append/fold/accumulate/barrier) return true; overwrite-style channels return false and trigger crate::TinyAgentsError::InvalidConcurrentUpdate on a same-step clash.

fn is_ready(&self, current: Option<&Value>) -> bool

Barrier readiness: whether the channel has received all the inputs it is waiting for. Non-barrier channels are always ready.

fn clone_box(&self) -> Box<dyn Channel>

Clones the channel into a fresh box (enables Clone for ChannelSet).

fn is_ephemeral(&self) -> bool

Whether the channel’s value is cleared at the start of the next step.

fn is_tracked(&self) -> bool

Whether the channel participates in ChannelSet::snapshot / durable state. Untracked returns false.

impl Clone for Barrier

fn clone(&self) -> Barrier

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Copy for Barrier

impl Debug for Barrier

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

Formats the value using the given formatter.