Method __anext__

acouchbase/datastructures.py:1082–1095

(self)

        return self

    async def __anext__(self):
        if self._iter is False:
            list_ = await self._get()
            self._full_queue = (v for v in list_.content_as[list])
            self._iter = True

        try:
            val = next(self._full_queue)
            # yield to the event loop
            await asyncio.sleep(0)
            return val
        except StopIteration:
            self._iter = False
            raise StopAsyncIteration