Method _close_stream

src/server/agent_server.py:148–152

(self)

            pass

    def _close_stream(self) -> None:
        try:
            self.loop.call_soon_threadsafe(self.out_queue.put_nowait, None)
        except RuntimeError:
            pass

    # ─── init ──────────────────────────────────────────────────────────────