Method stream_to_frontend

src/ServerTee.py:86–102

Yields log lines to a frontend until stop_event is set (if provided). This can be used in a Flask or FastAPI streaming endpoint.

(self, stop_event=None)

                self.subscribers.remove(q)

    def stream_to_frontend(self, stop_event=None):
        """
        Yields log lines to a frontend until stop_event is set (if provided).
        This can be used in a Flask or FastAPI streaming endpoint.
        """
        q = self.subscribe()
        try:
            while True:
                if stop_event and stop_event.is_set():
                    break
                try:
                    message = q.get(timeout=1)
                    yield message
                except Empty:
                    continue
        finally:
            self.unsubscribe(q)