async for”替换为普通的“for”循环,并在“await”调用之后使用“async_iter()”方法获取可迭代对象。
示例代码:
async def my_async_generator():
for i in range(10):
yield i
await asyncio.sleep(1)
# 错误示例:
async def my_coroutine():
async for i in my_async_generator():
print(i)
# 正确示例:
async def my_coroutine():
async_gen = my_async_generator()
async for i in range(10):
print(await async_gen.__anext__())