async def until_done(self) -> None:
        """Waits until the stream has been consumed"""
        await consume_async_iterator(self)
Waits until the stream has been consumed
src/anthropic/lib/streaming/_beta_messages.py