Struct StateStore 

pub struct StateStore {
    pub sessions: HashMap<SessionId, SessionState>,
    /* private fields */
}

All currently observed session projections.

Fields

sessions: HashMap<SessionId, SessionState>

Implementations

impl StateStore

pub fn apply_delivery(&mut self, delivery: ClientDelivery) -> DeliveryOutcome

Reduce every delivery variant from the single client stream. Replay events reduce into a per-session scratch projection. The visible projection changes only through a validated ReplayEnd swap or live events after that replay’s final sequence. Once a replay for a session is abandoned, that session’s visible projection is immutable until a validated replacement replay ends; all of its output is quarantined.

pub fn abandon_timed_out_replays(&mut self) -> Vec<SessionId>

Discard incomplete scratch replays. Their currently visible session projections remain intact for a full recovery attempt.

pub fn abandon_replays(&mut self) -> Vec<SessionId>

Discard all incomplete scratch replays after a connection closes.

pub fn take_voided_inputs(&mut self, session_id: SessionId) -> Vec<String>

Drain a session’s voided inputs for restoration into the composer. Returns them in admission (FIFO) order; empty when nothing is owed.

pub fn park_voided_input(&mut self, session_id: SessionId, text: String)

Park text as voided for a session (e.g. a recall resolved while a different session was being viewed); the UI restores it on sight.

pub fn apply_event(&mut self, event: StoredEvent) -> bool

Apply a persisted event. Replayed duplicates are ignored by sequence.

pub fn apply_event_for_generation( &mut self, event: StoredEvent, generation: u64, ) -> bool

pub fn apply_subscription( &mut self, message: EventSubscriptionMessage, ) -> Option<u64>

Apply a message from the event subscription stream. A gap is returned to allow callers to surface it; the client independently re-subscribes.

pub fn apply_subscription_for_generation( &mut self, message: EventSubscriptionMessage, generation: u64, ) -> Option<u64>

pub fn reset_session(&mut self, session_id: SessionId, generation: u64) -> bool

Drop a session projection before a full cursor-zero rebuild.

A visible projection is never reset while its replay scratch is active or its session is quarantined; callers receive false and must recover through the staged replay path instead.

pub fn rebuild_session( &mut self, session_id: SessionId, generation: u64, events: Vec<StoredEvent>, ) -> bool

Replace a session projection only after a complete contiguous replay is available. A failed/incomplete fetch leaves the existing projection intact.

Trait Implementations

impl Clone for StateStore

fn clone(&self) -> StateStore

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Debug for StateStore

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

Formats the value using the given formatter.

impl Default for StateStore

fn default() -> StateStore

Returns the “default value” for a type.