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 fn publish(&self, event: TaskEvent) -> usize

Publish an event. Returns number of receivers that got it.

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

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