Struct DeltaChannel 

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

Delta channel: append-heavy optimization with periodic snapshots

Tracks updates since the last snapshot and can replay writes for restoring from a delta-based checkpoint. The snapshot_frequency controls how often a full snapshot is taken instead of just recording the delta.

Implementations

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

pub fn new(value: T, snapshot_frequency: usize) -> Self

Create a new delta channel with the given initial value and snapshot frequency

The snapshot frequency is clamped to a minimum of 1.

pub fn replay_writes(&mut self, values: &[T])

where T: Clone + Serialize + DeserializeOwned,

Replay a sequence of writes to restore state from a checkpoint

During checkpoint recovery, finds the last Overwrite<T> in the sequence and uses it as the baseline, then applies only the writes after it via the reducer. This implements the design specification for ancestor replay.

pub const fn should_snapshot(&self) -> bool

Check if a snapshot is due based on the update count

pub const fn finish(&mut self)

Mark the channel as finished, forcing a snapshot on the next checkpoint call

This ensures the state is persisted when execution completes.

Trait Implementations

impl<T, R> Channel<T> for DeltaChannel<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 DeltaChannel<T, R>

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

Formats the value using the given formatter.