Struct SessionWakeQueue 

pub struct SessionWakeQueue { /* private fields */ }

Per-session mid-turn wake queue behind the registry seam.

Feed it by registering it as a TaskTransitionObserver on an crate::task_observer::ObservingTaskRegistry (or the server’s DbSessionTaskRegistry). Drain it from the turn loop with Self::drain.

Implementations

impl SessionWakeQueue

pub fn new() -> Self

pub fn note_transition( &self, task: &SessionTask, transition: TaskTransition, ) -> bool

Enqueue a wake for task’s owning session if its policy wakes on transition. Returns true when a wake was enqueued.

pub fn drain(&self, session_id: SessionId) -> Vec<PendingWake>

Atomically remove and return all wakes queued for session_id.

This is the exactly-once claim point: a drained wake is gone from the queue and can never be delivered again.

pub fn pending_len(&self, session_id: SessionId) -> usize

Number of wakes currently queued for session_id (not consuming).

pub fn has_pending(&self, session_id: SessionId) -> bool

Whether any wake is queued for session_id (not consuming).

Trait Implementations

impl Default for SessionWakeQueue

fn default() -> SessionWakeQueue

Returns the “default value” for a type.

impl TaskTransitionObserver for SessionWakeQueue

The queue is a TaskTransitionObserver so it can be attached to the same seam the server webhook dispatcher uses (EVE-729). Terminal and awaiting-input transitions render at full fidelity from the snapshot; a message transition renders from the snapshot’s progress/detail.

fn on_transition<'life0, 'life1, 'async_trait>( &'life0 self, task: &'life1 SessionTask, transition: TaskTransition, ) -> Pin<Box<dyn Future<Output = Result<()>> + Send + 'async_trait>>

where Self: 'async_trait, 'life0: 'async_trait, 'life1: 'async_trait,

Handle one task transition. Best-effort: returning Err is logged and never fails the task operation that produced the transition.