Struct SseBroadcaster 

pub struct SseBroadcaster { /* private fields */ }

Generic, string-keyed pub/sub fan-out for SSE-style event delivery.

Applications map their own session ids at the boundary. Non-blocking sends drop on a full subscriber channel so a slow consumer cannot stall the broadcaster.

Implementations

impl SseBroadcaster

pub fn new() -> Self

Creates an empty broadcaster.

pub fn subscribe(&self, app_key: &str) -> (String, Receiver<SseEvent>)

Registers a new subscriber for app_key.

Returns (subscriber_id, receiver). The channel is buffered (cap 100) so a transient slow consumer does not drop events immediately.

pub fn unsubscribe(&self, app_key: &str, subscriber_id: &str)

Removes a subscriber by id and closes its channel.

pub fn broadcast(&self, app_key: &str, event: SseEvent)

Sends an event to all subscribers for app_key.

Non-blocking: a full subscriber channel is skipped (drop-on-full) so one slow consumer cannot block the others.

pub fn close(&self, app_key: &str)

Closes all subscriber channels for app_key and removes the entry.

pub fn close_all(&self)

Closes every subscriber channel across all sessions.

Trait Implementations

impl Default for SseBroadcaster

fn default() -> Self

Returns the “default value” for a type.