Class PinRequiredFrame

python/src/cmdop/streaming.py:77–80

    async def __aiter__(self) -> AsyncIterator[AskFrame]:
        if self._started:
            raise RuntimeError("an AskStream can only be consumed once")
        self._started = True
        from cmdop._transport import _STREAM_END

        call_id, queue = await self._transport._start_stream(self._request)
        try:
            while True: