Struct SessionStreamBus 

pub struct SessionStreamBus { /* private fields */ }

Implementations

impl SessionStreamBus

pub fn new(capacity: usize) -> Self

pub fn subscribe(&self, session_id: &str) -> Receiver<Envelope>

pub fn publish(&self, session_id: &str, envelope: Envelope)

pub fn remove_if_unused(&self, session_id: &str) -> bool

Remove a session’s broadcast channel if it has no live receivers. Channels are created lazily on subscribe and were previously never removed — every session ever streamed pinned a map entry (and a lagging receiver pins up to capacity buffered envelopes) for the process lifetime. Called from session eviction; a channel with active receivers is left in place (false) and retried on the next sweep.

pub fn channel_count(&self) -> usize

Number of live channels (observability / tests).

Trait Implementations

impl Default for SessionStreamBus

fn default() -> Self

Returns the “default value” for a type.