class WebSocketUtils(pubSub: PubSubRegistry)(implicit ec: ExecutionContext) {
def topic(id: String) = pubSub.refFor(TopicIdString)
def subscribe(id: String) = topic(id).subscriber
def unsubscribe(id:String) = ??
}
class WebSocketUtils(pubSub: PubSubRegistry)(implicit ec: ExecutionContext) {
def topic(id: String) = pubSub.refFor(TopicIdString)
def subscribe(id: String) = topic(id).subscriber
def unsubscribe(id:String) = ??
}