Struct KeyedInFlightLedger 

pub struct KeyedInFlightLedger<K, C> { /* private fields */ }

Holds at most one in-flight item per key, drives their lifecycle uniformly, and records recognitions for latent queries. The keyed analogue of InFlightLedger, for calculators that track a candidate per subject (e.g. per player).

Implementations

impl<K, C> KeyedInFlightLedger<K, C>

pub fn new() -> Self

pub fn with_history_window(history_window: f32) -> Self

pub fn is_empty(&self) -> bool

pub fn len(&self) -> usize

impl<K: Eq + Hash + Clone, C> KeyedInFlightLedger<K, C>

pub fn arm(&mut self, key: K, item: C)

Arm (or replace) the in-flight item for key.

pub fn contains(&self, key: &K) -> bool

pub fn get(&self, key: &K) -> Option<&C>

pub fn get_mut(&mut self, key: &K) -> Option<&mut C>

pub fn entry_or_insert_with( &mut self, key: K, default: impl FnOnce() -> C, ) -> &mut C

Access the in-flight item for key, inserting one produced by default if absent. Mirrors HashMap::entry(..).or_insert_with(..).

pub fn keys(&self) -> impl Iterator<Item = &K> + '_

pub fn values(&self) -> impl Iterator<Item = &C> + '_

pub fn values_mut(&mut self) -> impl Iterator<Item = &mut C> + '_

pub fn iter(&self) -> impl Iterator<Item = (&K, &C)> + '_

pub fn iter_mut(&mut self) -> impl Iterator<Item = (&K, &mut C)> + '_

pub fn retain(&mut self, keep: impl FnMut(&K, &C) -> bool)

Keep only the items for which keep returns true, discarding the rest without finalizing them (e.g. pruning stale candidates).

pub fn discard(&mut self, key: &K) -> Option<C>

Remove the item for key without recording it as having happened (it is abandoned, not finalized).

pub fn clear(&mut self)

Discard every in-flight item without finalizing any (e.g. abandoning all candidates when their precondition no longer holds).

impl<K: Eq + Hash + Clone, C: InFlightItem> KeyedInFlightLedger<K, C>

pub fn finalize(&mut self, key: &K, _reason: FinalizeReason) -> Option<C>

Finalize the item for key, logging it for latent queries and returning it for the caller to convert into an event.

pub fn advance( &mut self, now: f32, step: impl FnMut(&K, &mut C) -> Disposition, ) -> Vec<(K, C, FinalizeReason)>

Advance every in-flight item with step, which receives the key and a mutable item and returns a Disposition. now bounds the latent-query history. Finalized items are returned with their key and reason.

pub fn apply_boundary( &mut self, boundary: Boundary, ) -> Vec<(K, C, FinalizeReason)>

Apply boundary to every in-flight item via InFlightItem::on_boundary.

pub fn finish(&mut self) -> Vec<(K, C, FinalizeReason)>

Finalize everything still in flight at end of stream.

pub fn happened_within( &self, now: f32, window: f32, committed_only: bool, ) -> bool

See InFlightLedger::happened_within.

pub fn recognitions_within( &self, now: f32, window: f32, committed_only: bool, ) -> impl Iterator<Item = Recognition> + '_

All recognitions within window seconds before now, across in-flight and finalized items.

Trait Implementations

impl<K: Clone, C: Clone> Clone for KeyedInFlightLedger<K, C>

fn clone(&self) -> Self

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl<K: Debug, C: Debug> Debug for KeyedInFlightLedger<K, C>

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

Formats the value using the given formatter.

impl<K, C> Default for KeyedInFlightLedger<K, C>

fn default() -> Self

Returns the “default value” for a type.

impl<K: Eq + Hash, C: PartialEq> PartialEq for KeyedInFlightLedger<K, C>

fn eq(&self, other: &Self) -> bool

Equality operator ==.

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

Inequality operator !=.