Struct RoomManager 

pub struct RoomManager { /* private fields */ }

Manages room subscriptions and message routing for a single channel.

Thread-safe via Arc<RwLock<...>> — designed for concurrent access from multiple WebSocket sessions and the Redis pub/sub listener.

Implementations

impl RoomManager

pub fn new() -> Self

Creates a new empty room manager.

pub async fn register_session( &self, session_id: &str, sender: UnboundedSender<String>, )

Registers a new session with its message sender.

pub async fn remove_session(&self, session_id: &str)

Removes a session and all its room subscriptions.

pub async fn subscribe(&self, session_id: &str, room: &str)

Subscribes a session to a room.

pub async fn unsubscribe(&self, session_id: &str, room: &str)

Unsubscribes a session from a room.

pub async fn broadcast_to_room(&self, room: &str, message: &str)

Broadcasts a text message to all sessions subscribed to a room.

pub async fn session_count(&self) -> usize

Returns the number of currently registered sessions.

pub async fn room_member_count(&self, room: &str) -> usize

Returns the number of sessions in a specific room.

Trait Implementations

impl Clone for RoomManager

fn clone(&self) -> RoomManager

Returns a duplicate of the value.

fn clone_from(&mut self, source: &Self)

Performs copy-assignment from source.

impl Default for RoomManager

fn default() -> Self

Returns the “default value” for a type.