Merging Async Iterables In Python3

Is there a good way, or a well-supported library, for merging async iterators in python3? The desired behavior is basically the same as that of merging observables in reactivex. Th

Solution 1:

You can use aiostream.stream.merge:

from aiostream import stream

asyncdefgo():
    asyncfor x in stream.merge(gen(), gen2()):
        print(x)

More examples in the documentation and this answer.