async def until_done(self) -> Self:
        """Blocks until the stream has been consumed."""
        await consume_async_iterator(self)
        return self
Blocks until the stream has been consumed.
src/openai/lib/streaming/responses/_responses.py