langchain/callbacks/streaming_aiter.py/AsyncIteratorCallbackHandler/on_llm_new_token
class AsyncIteratorCallbackHandler:    async def on_llm_new_token(self, token: str, **kwargs: Any) -> None:
        self.queue.put_nowait(token)