class

Obsctl::Server::ClientRegistry

Tracks IPC clients subscribed to pushed state, event, and log topics.

Constants

ALLOWED_TOPICS = Set {"state", "events", "logs"}

new

Creates an empty registry.

add(session : IPC::ClientSession, topics : Array(String)) : Nil

Adds or replaces a subscription for a connected client session.

broadcast(topic : String, data : JSON::Any | Nil = nil) : Nil

Broadcasts a topic event to all matching subscribers.

client_count

Returns the current number of registered client sessions.

remove(session : IPC::ClientSession) : Nil

Removes a client session from the registry.