search

dbrattli / aioreactive

Async/await reactive tools for Python 3.11+
MIT License
350 stars 24 forks source link

Concat with async iterables #17

Open tr11 opened 6 years ago

tr11 commented 6 years ago

I'm trying to adapt the concat operator to implement the catch_exception op, but just noticed that the concat fails with an async iterable. I'm using the following observable:

async def asynciter():
    for i in range(5):
        await asyncio.sleep(1)
        yield i
xs = from_async_iterable(asynciter())

I have a fork with a working catch_exception and retry here, as well as the tests mentioned: https://github.com/tr11/aioreactive/commit/6219f9a0761f69fa1765129b990762affdf661c8