Struct TopicChannel 

pub struct TopicChannel<T> { /* private fields */ }

Topic channel: accumulates all published values into a list

This channel implements pub/sub messaging patterns where all writes are accumulated into a list. Each value is appended independently, allowing multiple publishers to send messages to the same topic.

Type Parameters

• T - The message type stored in the topic

Examples

use juncture_core::state::channel::TopicChannel;

let mut channel: TopicChannel<String> = TopicChannel::new();

// Publish messages
channel.update(vec!["hello".to_string()]);
channel.update(vec!["world".to_string()]);

// Get all accumulated messages
let messages = channel.get();
assert_eq!(messages.len(), 2);
assert_eq!(messages[0], "hello");
assert_eq!(messages[1], "world");

// Reset for next superstep
channel.reset();
assert!(messages.is_empty());

Implementations

impl<T> TopicChannel<T>

pub const fn new() -> Self

Create a new empty topic channel

pub const fn len(&self) -> usize

Get the number of messages in the topic

pub const fn is_empty(&self) -> bool

Check if the topic is empty

pub fn reset(&mut self)

Reset the topic, clearing all messages

This is typically called at the start of each superstep to clear ephemeral message accumulations.

pub fn iter(&self) -> Iter<'_, T>

Get an iterator over the messages

Trait Implementations

impl<T> Channel<Vec<T>> for TopicChannel<T>

where T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static,

fn update(&mut self, values: Vec<Vec<T>>) -> bool

Update the channel with new values. Returns true if the value changed.

fn get(&self) -> &Vec<T>

Get the current value

fn consume(&mut self) -> bool

Check if the channel has been consumed (for trigger-based activation)

fn checkpoint(&self) -> Option<Value>

Create a checkpoint of the current value for persistence

fn from_checkpoint(value: Value) -> Result<Self, String>

where Self: Sized,

Restore from a checkpoint value

impl<T: Clone> Clone for TopicChannel<T>

fn clone(&self) -> TopicChannel<T>

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug> Debug for TopicChannel<T>

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

Formats the value using the given formatter.

impl<T> Default for TopicChannel<T>

fn default() -> Self

Returns the “default value” for a type.

impl<'a, T> IntoIterator for &'a TopicChannel<T>

type Item = &'a T

The type of the elements being iterated over.

type IntoIter = Iter<'a, T>

Which kind of iterator are we turning this into?

fn into_iter(self) -> Self::IntoIter

Creates an iterator from a value.