asyncstdlib

import asyncio import asyncstdlib as a async def async_counter(limit: int): """An async generator that yields numbers up to a limit.""" for i in range(limit): await asyncio.sleep(0.01) # Simulate async work yield i async def main(): print("\nMapping values (doubling):") doubled_values = a.itertools.map(lambda x: x * 2, async_counter(5)) async for item in doubled_values: print(item) print("\nFiltering values (evens only):") even_values = a.itertools.filter(lambda x: x % 2 == 0, async_counter(6)) async for item in even_values: print(item) print("\nConsuming with anext:") it = a.builtins.aiter(async_counter(3)) print(await a.builtins.anext(it)) print(await a.builtins.anext(it)) if __name__ == "__main__": asyncio.run(main())