Replymessage unavailable
import asyncio
async def collect_from_generator(gen):
return [item async for item in gen]
async def concurrent_example():
# 并发执行两个异步生成器
result1, result2 = await asyncio.gather(
collect_from_generator(async_generator1()),
collect_from_generator(async_generator2())
)