asyncstdlib_map_and_list_with_async_generator.py

1import asyncio
2import asyncstdlib as ast
3
4async def slow_count(to: int):
5    """An async generator that yields numbers with a delay"""
6    for i in range(to):
7        yield i
8        await asyncio.sleep(0.1)
9
10async def main():
11    # Use asyncstdlib.map to transform an async iterator
12    doubled = ast.map(lambda x: x * 2, slow_count(5))
13    
14    # Use asyncstdlib.list to collect the results
15    results = await ast.list(doubled)
16    print(f"Processed results: {results}")
17
18if __name__ == "__main__":
19    asyncio.run(main())