Tutorials Programming Tutorials, Guides & Best Practices

Coroutines can mimic generator pipelines, but they work asynchronously:

async def produce_numbers():
    for i in range(5):
        await asyncio.sleep(0.5)
        yield i

async def consume_numbers(numbers):
    async for num in numbers:
        print(f"Consumed {num}")

async def main():
    await consume_numbers(produce_numbers())

asyncio.run(main())