Class PinDeniedFrame

python/src/cmdop/streaming.py:84–87

        try:
            while True:
                try:
                    item = await asyncio.wait_for(queue.get(), self._timeout)
                except (TimeoutError, asyncio.TimeoutError) as exc:
                    raise CmdopTimeoutError(
                        "agent stream timed out", code="deadline_exceeded"
                    ) from exc
                if item is _STREAM_END: