ReactiveX / RxPY
94%

DEFAULT BRANCH: master
Repo Added
Files 417
Badge
Embed ▾
README BADGES
x

If you need to use a raster PNG badge, change the '.svg' to '.png' in the link

Markdown

Textile

RDoc

HTML

Rst

LAST BUILD ON BRANCH master
branch: SELECT
CHANGE BRANCH
x

coverage: 93.618% (+0.04%) from 93.574%
29865117778

push

github

web-flow 
fix(operators): accept concurrent.futures.Future wherever futures are accepted (#806)

Since the 3.0 rewrite every operator tested for futures with
`isinstance(x, asyncio.Future)`, so a `concurrent.futures.Future` fell
through to `from_(...)` and raised `TypeError: 'Future' object is not
iterable`. RxPY 2 duck-typed futures via `add_done_callback` and accepted
both flavours.

Restore that behaviour: add a public `reactivex.typing.AnyFuture[T]` alias
(`asyncio.Future[T] | concurrent.futures.Future[T]`) and an internal
`is_future()` TypeIs guard, and use them at all 16 isinstance sites --
flat_map, merge, amb, catch, exclusive, skip_until, switch_latest,
take_until, timeout, while_do, case, defer, if_then, zip,
on_error_resume_next and from_future.

`from_future()` already worked with both kinds at runtime; only its
annotation said otherwise. `to_future()` keeps returning an
`asyncio.Future`, since it constructs one.

Also widen the annotations so the pattern type-checks: `flat_map` gains
future-returning overloads, `merge_all` accepts futures as inner sources,
and the `amb`/`take_until`/`timeout` facades now match their impls.

examples/parallel/timer.py works again as written, and gains the
`__main__` guard that ProcessPoolExecutor needs on non-fork start methods.

Fixes #709

Co-authored-by: Claude Opus 4.8 (1M context) <noreply@anthropic.com>

191 of 191 new or added lines in 23 files covered. (100.0%)

25702 of 27454 relevant lines covered (93.62%)

0.94 hits per line

Relevant lines Covered
27454 RELEVANT LINES 25702 COVERED LINES
0.94 HITS PER LINE
Source Files on master

Recent builds

Builds Branch Commit Type Ran Committer Via Coverage
29865117778 master fix(operators): accept concurrent.futures.Future wherever futures are accepted (#806) Since the 3.0 rewrite every operator tested for futures with `isinstance(x, asyncio.Future)`, so a `concurrent.futures.Future` fell through to `from_(...)` and ... push web-flow github
93.62
29864824147 fix/709-concurrent-futures fix(operators): accept concurrent.futures.Future wherever futures are accepted Since the 3.0 rewrite every operator tested for futures with `isinstance(x, asyncio.Future)`, so a `concurrent.futures.Future` fell through to `from_(...)` and raised ... Pull #806 dbrattli github
93.62
29863867828 master fix(gtk): call gi.require_version before importing gi.repository (#749) * Call gi.require_version before importing, instead of after * fix(gtk): skip cleanly when GTK 3 is unavailable, pin Gdk in example require_version() raises ValueError when... push web-flow github
93.57
29863477558 gi-require_version-before-import Merge a18c560a7 into 95c54ac36 Pull #749 web-flow github
93.57
29861651388 master feat(operators): add tap as an alias for do_action (#804) `tap` existed as an alias for `do_action` from 2014 until the RxPY 3.0 rewrite. It was provided by the `@extensionmethod(Observable, alias=...)` decorator, and disappeared in 5be144c1 (201... push web-flow github
93.58
29861267530 feat/tap-operator feat(operators): add tap as an alias for do_action `tap` existed as an alias for `do_action` from 2014 until the RxPY 3.0 rewrite. It was provided by the `@extensionmethod(Observable, alias=...)` decorator, and disappeared in 5be144c1 (2017-12-16... Pull #804 dbrattli github
93.58
29811703340 master docs: fix broken Sphinx build and refresh docs for 5.0 (#803) The documentation build has been broken since the Poetry-to-uv migration. docs/conf.py read project metadata from the `[tool.poetry]` table, which no longer exists, so `config["tool"][... push web-flow github
93.56
29811304037 docs/fix-build-and-5.0-refresh docs: fix broken Sphinx build and refresh docs for 5.0 The documentation build has been broken since the Poetry-to-uv migration. docs/conf.py read project metadata from the `[tool.poetry]` table, which no longer exists, so `config["tool"]["poetry... Pull #803 dbrattli github
93.56
29774556012 master chore: release reactivex@5.0.0 (#801) Co-authored-by: 🤖 easybuild-shipit <github-actions[bot]@users.noreply.github.com> push web-flow github
93.56
29774115213 release/master Merge dabc10e18 into 10ccc0a3d Pull #801 web-flow github
93.56
See All Builds (1446)