Method _emit

src/server/agent_server.py:135–146

Thread-safe enqueue of one outbound SDK message. Every message is passed through ``_json_safe`` so a stray non-serializable value can never make the server's ``json.dumps`` in the WS pump raise and silently kill the outbound stream.

(self, msg: dict)

    # ─── outbound helpers (worker thread → main loop) ──────────────────────

    def _emit(self, msg: dict) -> None:
        """Thread-safe enqueue of one outbound SDK message.

        Every message is passed through ``_json_safe`` so a stray
        non-serializable value can never make the server's ``json.dumps`` in
        the WS pump raise and silently kill the outbound stream.
        """
        try:
            self.loop.call_soon_threadsafe(self.out_queue.put_nowait, _json_safe(msg))
        except RuntimeError:
            # Loop closed (server shutting down) — drop.
            pass

    def _close_stream(self) -> None:
        try: