Method _reader_loop

benches/memory_usage.py:196–230

Continuously read messages and dispatch them.

(self)

    # ── Background reader ────────────────────────────────────────────

    def _reader_loop(self) -> None:
        """Continuously read messages and dispatch them."""
        try:
            while not self._stopped:
                try:
                    msg = _read_message(self._proc.stdout)
                except EOFError:
                    break

                # Is this a response to one of our requests?
                if "id" in msg and "method" not in msg:
                    rid = msg["id"]
                    with self._pending_lock:
                        q = self._pending.get(rid)
                    if q is not None:
                        q.put(msg)
                    continue

                # Is this a server-to-client request that needs a reply?
                method = msg.get("method", "")
                if method in self._SERVER_REQUESTS and "id" in msg:
                    self._send_raw({
                        "jsonrpc": "2.0",
                        "id": msg["id"],
                        "result": None,
                    })
                    # Also forward as a notification so callers can
                    # observe it (e.g. progress token creation).
                    self._notifications.put(msg)
                    continue

                # Everything else is a notification.
                self._notifications.put(msg)
        except Exception as exc:
            self._reader_error = exc

    # ── Transport ────────────────────────────────────────────────────