Struct EventBus 

pub struct EventBus { /* private fields */ }

The event bus — wraps a tokio broadcast channel.

Implementations

impl EventBus

pub fn new(capacity: usize) -> Self

pub fn sender(&self) -> Sender<TaskEvent>

Get a sender clone (for TaskManager, subscribers, etc.).

pub fn subscribe(&self) -> Receiver<TaskEvent>

Subscribe to events.

pub async fn start_ws_server(&self) -> Result<u16>

Start the websocket server. Returns the bound port. Spawns a background task — does not block.

Trait Implementations

impl Debug for EventBus

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

Formats the value using the given formatter.