dbrattli / dbrattli/aioreactive

Concat with async iterables

Open
#17 0 comments 0 reactions 0 assignees View on GitHub
Dominant language
Python
Stars
401
Forks
25
PR merge metrics
No merged PRs in 30d

Description

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

Contributor guide

No contributing guide indexed for this repository

Research direction

Start with the concat operator and the from_async_iterable example in the issue. Compare the working catch_exception and retry changes and their tests in commit 6219f9a0761f69fa1765129b990762affdf661c. Done means concat works with the shown async iterable and the mentioned tests pass.

Written by the indexing model from the issue text.

Assessment

Tech stack
python
Domain
backend
Issue type
Bug
Difficulty
3/5
Estimated time
1-2 days
Activity status
Stale
Clarity
Mostly clear
Newbie friendliness
38/100

Get new issues in your inbox

A short digest of beginner-friendly GitHub issues.