Struct RoomManager 

pub struct RoomManager { /* private fields */ }

Manages named rooms with membership, presence, and broadcasting.

Rooms are created lazily on first join and removed when the last member leaves. Each room tracks its members, their ephemeral state (typing, cursors, custom data), and supports topic-scoped broadcasting.

Implementations

impl RoomManager

pub fn new(idle_timeout_secs: u64) -> Self

pub fn with_max_rooms(idle_timeout_secs: u64, max_rooms: usize) -> Self

Create a RoomManager with a custom maximum room limit.

pub fn join( &self, room: &str, user_id: &str, data: Option<Value>, ) -> Result<(RoomEvent, RoomEvent), RoomError>

Join a room. Creates the room if it doesn’t exist. Returns a snapshot of current peers (before this join) and the join event, or an error if the room limit has been reached and this would create a new room.

pub fn leave(&self, room: &str, user_id: &str) -> Option<RoomEvent>

Leave a room. Removes the room if it becomes empty. Returns the leave event, or None if the user wasn’t in the room.

pub fn set_presence( &self, room: &str, user_id: &str, data: Value, ) -> Option<RoomEvent>

Update a member’s ephemeral state (typing indicator, cursor position, etc.). Returns a presence event, or None if not in the room.

pub fn get_presence(&self, room: &str, user_id: &str) -> Option<Value>

Get a member’s current ephemeral data.

pub fn broadcast( &self, room: &str, sender: Option<&str>, topic: &str, data: Value, ) -> Option<RoomEvent>

Broadcast an arbitrary event to a room. Returns the broadcast event, or None if the room doesn’t exist.

pub fn members(&self, room: &str) -> Vec<PeerInfo>

List all members currently in a room.

pub fn list_rooms(&self) -> Vec<String>

List all active room names.

pub fn is_in_room(&self, room: &str, user_id: &str) -> bool

Check if a user is in a specific room.

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

Get the number of members in a room.

pub fn disconnect(&self, user_id: &str) -> Vec<RoomEvent>

Remove a user from ALL rooms they’re in. Returns leave events.

pub fn cleanup_idle(&self) -> Vec<RoomEvent>

Remove idle members from all rooms. Returns leave events for each removed member.

pub fn user_rooms(&self, user_id: &str) -> Vec<String>

Get all rooms a user is currently in.

Trait Implementations

impl RoomOps for RoomManager

fn join( &self, room: &str, user_id: &str, data: Option<Value>, ) -> Result<(Value, Value), DataError>

fn leave(&self, room: &str, user_id: &str) -> Option<Value>

fn set_presence(&self, room: &str, user_id: &str, data: Value) -> Option<Value>

fn broadcast( &self, room: &str, sender: Option<&str>, topic: &str, data: Value, ) -> Option<Value>

fn list_rooms(&self) -> Vec<String>

fn room_size(&self, name: &str) -> usize

fn members(&self, name: &str) -> Vec<Value>