Method __init__

server/lib/sseserver.py:25–26

(self)

class SSEQueueWithTopic:
    def __init__(self):
        self.pubsub : dict[str, SSEQueue] = {}

    def listen(self, topic: str):
        logger.info(f"LISTENING TO: {topic}")