Function _read_delimited

python/src/cmdop/_transport.py:62–77

Read one length-delimited protobuf body off ``reader``. Reads the varint length one byte at a time (high bit = continue), then the exact body. ``readexactly`` has no buffer-size cap, so there is no 64 KB readline trap (report 13 §1.4 — this is *why* proto framing replaced NDJSON). R

(reader: asyncio.StreamReader)

def _fail_stream(queue: asyncio.Queue[object], error: Exception) -> None:
    """Discard buffered frames and deliver one terminal error without blocking."""
    while True:
        try:
            queue.get_nowait()
        except asyncio.QueueEmpty:
            break
    queue.put_nowait(error)
    queue.put_nowait(_STREAM_END)


class Transport:
    def __init__(self, config: ClientConfig, binary_path: str) -> None:
        self._config = config
        self._binary_path = binary_path
        self._process: asyncio.subprocess.Process | None = None
        self._reader_task: asyncio.Task[None] | None = None
        self._stderr_task: asyncio.Task[None] | None = None
        self._pending: dict[int, _UnaryPending | _StreamPending] = {}