multun

import asyncio

async def merge_iter(iterables):
    # create async iterators from the iterables
    iterators = [iterable.__aiter__() for iterable in iterables]

    # create an next() task per iterator
    tasks = {asyncio.ensure_future(it.__anext__()): it for it in iterators}
    try:
        while tasks: