Struct RepoEventBus 

pub struct RepoEventBus { /* private fields */ }

A per-repository event bus backed by tokio::sync::broadcast.

Channels are lazily created on first publish or subscribe for a given repo. Slow consumers that fall behind will receive RecvError::Lagged, which is non-fatal — they skip missed events.

Implementations

impl RepoEventBus

pub fn new() -> Self

Create a new, empty event bus.

pub fn publish(&self, repo_id: RepoId, event: SessionEvent)

Publish an event to all subscribers of the given repository.

If no subscribers exist yet, the event is silently dropped (the channel is still created for future subscribers).

pub fn subscribe(&self, repo_id: RepoId) -> Receiver<SessionEvent>

Subscribe to events for a repository.

Returns a broadcast::Receiver that yields SessionEvents.

pub fn active_repos(&self) -> usize

Number of repositories with active channels.

pub fn subscriber_count(&self, repo_id: RepoId) -> usize

Number of active subscribers for a given repo.

Returns 0 if no channel exists for the repo.

pub fn prune_dead_channels(&self)

Remove channels with no active subscribers.

Trait Implementations

impl Default for RepoEventBus

fn default() -> Self

Returns the “default value” for a type.