Struct Topic 

pub struct Topic<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> { /* private fields */ }

Topic — collects multiple updates into a list per step. PubSub style. Multiple nodes can write to the same topic in one superstep.

Implementations

impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Topic<T>

pub fn new() -> Self

pub fn get(&self) -> &[T]

Trait Implementations

impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Channel for Topic<T>

fn merge(&mut self, update: Box<dyn Any + Send>)

Merge a boxed update value into this channel.

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

Clone the channel (for snapshot isolation during parallel execution).

fn clear(&mut self)

Clear the channel (for ephemeral values — called between supersteps).

fn is_ephemeral(&self) -> bool

Whether this channel should be cleared between supersteps.

fn checkpoint(&self) -> Result<Vec<u8>, PeError>

Serialize channel state for checkpointing.

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

Name of this channel type (for debugging).

fn as_any(&self) -> &dyn Any

Downcast support — returns self as &dyn Any.

fn as_any_mut(&mut self) -> &mut dyn Any

Downcast support — returns self as &mut dyn Any.

impl<T: Clone + Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Clone for Topic<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Debug for Topic<T>

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

Formats the value using the given formatter.

impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Default for Topic<T>

fn default() -> Self

Returns the “default value” for a type.