Enum CuLatchedState 

pub enum CuLatchedState<T: Clone> {
    Unset,
    Set(T),
}

Consumer-side cache updated by CuLatchedStateUpdate.

This is typically stored in a task struct and updated as messages arrive. It is not a runtime-managed global store; each consumer keeps its own copy of the latched state so replay and deterministic execution follow the same update sequence as live execution.

Variants

Unset

No value has been latched yet, or the previous value was cleared.

Set(T)

The most recently latched value.

Implementations

impl<T: Clone> CuLatchedState<T>

pub fn new() -> Self

Creates an empty latched state.

pub fn is_set(&self) -> bool

Returns true when a value is currently latched.

pub fn is_unset(&self) -> bool

Returns true when no value is currently latched.

pub fn get(&self) -> Option<&T>

Returns the currently latched value, if any.

pub fn as_ref(&self) -> Option<&T>

Returns the currently latched value as a shared reference, if any.

This is equivalent to Self::get.

pub fn set(&mut self, value: T)

Replaces the currently latched value.

pub fn clear(&mut self)

Clears the currently latched value.

pub fn take(&mut self) -> Option<T>

Removes and returns the currently latched value, leaving the state unset.

pub fn update_owned(&mut self, update: CuLatchedStateUpdate<T>)

Applies an owned update without cloning the payload value.

impl<T: Clone> CuLatchedState<T>

pub fn update(&mut self, update: &CuLatchedStateUpdate<T>)

Applies a borrowed update, cloning only when the update contains a new value.

Trait Implementations

impl<'__de, T, __Context> BorrowDecode<'__de, __Context> for CuLatchedState<T>

where T: BorrowDecode<'__de, __Context> + Clone,

fn borrow_decode<__D: BorrowDecoder<'__de, Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given BorrowDecode.

impl<T: Clone + Clone> Clone for CuLatchedState<T>

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

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<T: Debug + Clone> Debug for CuLatchedState<T>

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

Formats the value using the given formatter.

impl<T, __Context> Decode<__Context> for CuLatchedState<T>

where T: Decode<__Context> + Clone,

fn decode<__D: Decoder<Context = __Context>>( decoder: &mut __D, ) -> Result<Self, DecodeError>

Attempt to decode this type with the given Decode.

impl<T: Clone> Default for CuLatchedState<T>

fn default() -> CuLatchedState<T>

Returns the “default value” for a type.

impl<'de, T> Deserialize<'de> for CuLatchedState<T>

where T: Deserialize<'de> + Clone,

fn deserialize<__D>(__deserializer: __D) -> Result<Self, __D::Error>

where __D: Deserializer<'de>,

Deserialize this value from the given Serde deserializer.

impl<T> Encode for CuLatchedState<T>

where T: Encode + Clone,

fn encode<__E: Encoder>(&self, encoder: &mut __E) -> Result<(), EncodeError>

Encode a given type.

impl<T: PartialEq + Clone> PartialEq for CuLatchedState<T>

fn eq(&self, other: &CuLatchedState<T>) -> bool

Tests for self and other values to be equal, and is used by ==.

fn ne(&self, other: &Rhs) -> bool

Tests for !=. The default implementation is almost always sufficient, and should not be overridden without very good reason.

impl<T> Serialize for CuLatchedState<T>

where T: Serialize + Clone,

fn serialize<__S>(&self, __serializer: __S) -> Result<__S::Ok, __S::Error>

where __S: Serializer,

Serialize this value into the given Serde serializer.

impl<T: Clone> TypePath for CuLatchedState<T>

fn type_path() -> &'static str

fn short_type_path() -> &'static str

fn type_ident() -> Option<&'static str>

fn crate_name() -> Option<&'static str>

fn module_path() -> Option<&'static str>

impl<T: Clone> StructuralPartialEq for CuLatchedState<T>