Struct LastValueAfterFinishChannel 

pub struct LastValueAfterFinishChannel<T, R: Reducer<T>> { /* private fields */ }

Last-value-after-finish channel: value only available after finish() is called

Before finish(), get() returns the default value. After finish(), the written value becomes available. Checkpoints persist only if finished.

Implementations

impl<T, R: Reducer<T>> LastValueAfterFinishChannel<T, R>

pub const fn new(value: T) -> Self

Create a new channel with the given default value

pub const fn finish(&mut self)

Mark the channel as finished, making the value available

pub const fn is_available(&self) -> bool

Check if the channel has been finished and the value is available

Trait Implementations

impl<T, R> Channel<T> for LastValueAfterFinishChannel<T, R>

where T: Default + Clone + Send + Sync + Serialize + DeserializeOwned + 'static, R: Reducer<T> + Send + Sync + 'static,

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

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

fn get(&self) -> &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>

Restore from a checkpoint value

impl<T: Debug, R: Debug + Reducer<T>> Debug for LastValueAfterFinishChannel<T, R>

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

Formats the value using the given formatter.