langchain/callbacks/streaming_aiter.py/AsyncIteratorCallbackHandler/__init__
class AsyncIteratorCallbackHandler:    def __init__(self) -> None:
        self.queue = asyncio.Queue()
        self.done = asyncio.Event()