Method notify_subscribers

src/ServerTee.py:68–73

(self, message)

    # -------------------

    def notify_subscribers(self, message):
        for subscriber in list(self.subscribers):  # copy to avoid mutation during iteration
            try:
                subscriber.put_nowait(message)
            except Exception:
                pass  # subscriber queue full or closed

    def subscribe(self):
        q = Queue()