Struct StreamRegistry 

pub struct StreamRegistry { /* private fields */ }

Central registry for all active streams

Thread-safe via RwLock. Read-heavy workloads (subscriber count checks, broadcasting) benefit from the concurrent read access.

Implementations

impl StreamRegistry

pub fn new() -> Self

Create a new stream registry with default configuration

pub fn with_config(config: RegistryConfig) -> Self

Create a new stream registry with custom configuration

pub fn config(&self) -> &RegistryConfig

Get the registry configuration

pub async fn register_publisher( &self, key: &StreamKey, session_id: u64, ) -> Result<(), RegistryError>

Register a publisher for a stream

If the stream doesn’t exist, it will be created. If the stream exists and is in grace period, the publisher reclaims it. Returns an error if the stream already has an active publisher.

pub async fn unregister_publisher(&self, key: &StreamKey, session_id: u64)

Unregister a publisher from a stream

The stream enters grace period if there are active subscribers, allowing the publisher to reconnect.

pub async fn subscribe( &self, key: &StreamKey, ) -> Result<(Receiver<BroadcastFrame>, Vec<BroadcastFrame>), RegistryError>

Subscribe to a stream

Returns a broadcast receiver and catchup frames for the subscriber. The catchup frames contain sequence headers and recent GOP data.

pub async fn unsubscribe(&self, key: &StreamKey)

Unsubscribe from a stream

pub async fn broadcast(&self, key: &StreamKey, frame: BroadcastFrame)

Broadcast a frame to all subscribers of a stream

Also updates the GOP buffer and sequence headers as needed.

pub async fn get_sequence_headers(&self, key: &StreamKey) -> Vec<BroadcastFrame>

Get sequence headers for a stream (video and audio decoder config)

Used when resuming playback after pause to reinitialize decoders.

pub async fn has_active_stream(&self, key: &StreamKey) -> bool

Check if a stream exists and has an active publisher

pub async fn stream_exists(&self, key: &StreamKey) -> bool

Check if a stream exists (active or in grace period)

pub async fn get_stream_stats(&self, key: &StreamKey) -> Option<StreamStats>

Get stream statistics

pub async fn stream_count(&self) -> usize

Get total number of streams

pub async fn cleanup(&self)

Run cleanup task once

Removes streams that have:

• Been in grace period longer than publisher_grace_period
• Been idle longer than idle_stream_timeout

pub fn spawn_cleanup_task(self: &Arc<Self>) -> JoinHandle<()>

Spawn background cleanup task

Returns a handle that can be used to abort the task.

Trait Implementations

impl Default for StreamRegistry

fn default() -> Self

Returns the “default value” for a type.