async def __anext__(self):
        """Return the next 1k chunk from the raw stream.
        """
        current_chunk = await self.read(self._DEFAULT_CHUNK_SIZE)
        if current_chunk:
            return current_chunk
        raise StopAsyncIteration
async def __anext__ ( self ) : current_chunk = await self . read ( self . _DEFAULT_CHUNK_SIZE ) if current_chunk : return current_chunk raise StopAsyncIteration
Return the next 1k chunk from the raw stream.