Struct PredictionBuffer 

pub struct PredictionBuffer<A, S>
where
    A: Copy,
    S: Copy,
{ /* private fields */ }

Rolling buffer of unacknowledged inputs + matching predicted snapshots, sized so the oldest entry is dropped when the ring is full.

Implementations

impl<A, S> PredictionBuffer<A, S>

where A: Copy + Debug, S: Copy + Debug,

pub fn new(capacity: usize) -> Self

Construct a buffer that retains at most capacity entries.

Panics

Panics if capacity == 0.

pub fn len(&self) -> usize

Number of buffered entries.

pub fn is_empty(&self) -> bool

True when no inputs are buffered.

pub fn push(&mut self, input: PredictedInput<A>, snapshot: Snapshot<S>)

Push a (input, snapshot) pair. Drops the oldest entry when the ring is full. The snapshot MUST be the result of applying input to the previous state — the buffer does not verify this.

pub fn head_snapshot(&self) -> Option<Snapshot<S>>

Head (newest) snapshot, if any.

pub fn inputs(&self) -> &[PredictedInput<A>]

All buffered inputs.

pub fn drop_acknowledged(&mut self, authoritative_tick: u64)

Drop every entry with tick <= authoritative_tick. Used after reconcile to discard now-obsolete predictions.

Trait Implementations

impl<A, S> Clone for PredictionBuffer<A, S>

where A: Copy + Clone, S: Copy + Clone,

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<A, S> Debug for PredictionBuffer<A, S>

where A: Copy + Debug, S: Copy + Debug,

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

Formats the value using the given formatter.