Struct PendingNotificationQueue 

pub struct PendingNotificationQueue { /* private fields */ }

Thread-safe queue for notifications from background threads.

Registered as a Service in ServiceRegistry so that both the background threads (which have Arc<ServiceRegistry>) and the command handler (which has SessionRuntime) can access it.

Implementations

impl PendingNotificationQueue

pub const fn new() -> Self

Create a new empty queue.

pub fn push(&self, level: PendingLevel, title: impl Into<String>)

Push a simple notification from any thread.

Convenience method for sourceless push operations. For source-tagged or progress notifications, use push_op.

pub fn push_op(&self, source: Option<String>, op: PendingOp)

Push a notification operation with optional source attribution.

pub fn drain(&self) -> Vec<PendingEntry>

Drain all pending entries.

Called from the command handler context where SessionRuntime is available to forward them to the display system.

pub fn len(&self) -> usize

Number of pending entries.

pub fn is_empty(&self) -> bool

Whether the queue is empty.

Trait Implementations

impl Debug for PendingNotificationQueue

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

Formats the value using the given formatter.

impl Default for PendingNotificationQueue

fn default() -> Self

Returns the “default value” for a type.

impl Service for PendingNotificationQueue