Struct LastValue 

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

LastValue — stores the last written value. Default channel type. At most one update per step. Last write wins.

Implementations

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

pub fn new(initial: T) -> Self

pub fn get(&self) -> &T

Trait Implementations

impl<T: Clone + Send + Sync + Serialize + DeserializeOwned + 'static> Channel for LastValue<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 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.

fn is_ephemeral(&self) -> bool

Whether this channel should be cleared between supersteps.

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

fn clone(&self) -> LastValue<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 LastValue<T>

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

Formats the value using the given formatter.