Struct CommandBus 

pub struct CommandBus { /* private fields */ }

Bounded, non-blocking fan-out of commands received by the daemon.

Every omni listen connection gets its own queue. A stalled subscriber can drop its own events, but can never delay OS injection or other subscribers.

Implementations

impl CommandBus

pub fn new() -> Self

pub fn publish(&self, cmd: &InjectionCommand)

Publish without blocking the command/injection path. Full queues drop the newest event; disconnected subscribers are removed.

pub fn publish_event(&self, event: &SemanticEvent) -> usize

Non-injecting events use a separate opt-in subscriber set.

pub fn event_subscriber_count(&self) -> usize

pub fn subscriber_count(&self) -> usize

Number of currently connected local command stream subscribers.

Trait Implementations

impl Clone for CommandBus

fn clone(&self) -> CommandBus

Returns a duplicate of the value.

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

Performs copy-assignment from source.

impl Default for CommandBus

fn default() -> CommandBus

Returns the “default value” for a type.