Method __anext__

gunicorn/dirty/client.py:530–538

(self)

        return self

    async def __anext__(self):
        if self._exhausted:
            raise StopAsyncIteration

        if not self._started:
            await self._start_request()
            self._started = True

        return await self._read_next_chunk()

    async def _start_request(self):
        """Send the initial request to the arbiter."""