NewYour coding agent can read the release notes before it upgrades.Set up the MCP server →
PyPI · #2834 most downloaded on PyPI
Reactive Extensions (Rx) for Python
Last release 4 years ago
no release in 18 months
Release timing varies
gaps range from 3 weeks to 1.6 years
Some releases are documented
notes for 13 of 25 stable releases
Nothing withdrawn
no release was ever pulled
12 years old
25 releases · first in 2014
This is an improvement and bugfix release.
This is an improvement and bugfix release.
This is a bugfix and performance improvment release.
This is a bugfix and performance improvment release.
Fixes:
Performance:
Other:
One column per quarter.
This is a bugfix and enhancement release. The principal evolutions are:
This is a bugfix and enhancement release. The principal evolutions are:
Nothing published for this version
Replaced method chaining with a pipe-based functional API as the recommended style.
concurrency package to scheduler; split mainloop and
eventloop schedulers into their own modules.amb, combine_latest, concat,
merge, on_error_resume_next, catch, zip) — the leading Iterable
argument is gone.result_mapper from join, group_join, zip, generate.py.typed marker (PEP 561).AnonymousObservable into Observable.catch_exception to catch.TrampolineScheduler and priority-queue scheduler improvements.run() function.Nothing published for this version
Nothing published for this version
Nothing published for this version
This release of RxPy has a number of enhancements and fixes, including:
This release of RxPy has a number of enhancements and fixes, including:
Rolling initialization state bug with to_list() has been resolved #156
auto_connect() functionality added to ConnectableObservable #164
Several doXXX() side effect operators, as well as concat_map() and from_callable(), were added to mirror RxJava2 #166 #164
A to_sorted_list() operator has been added to collect emissions into a sorted list #167
A small set of statistical operators (median(), mode(), standard_deviation(), variance()) has been added #167
BlockingObservable received first(), first_or_default(), last(), and last_or_default() operators #172
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Nothing published for this version
Fixes for TwistedScheduler raising AlreadyCalled error #78. Thanks to @mchen402 and @jcwilson.
Added wxscheduler.py for use with wxPython applications thanks to @bosonogi
Threads are now daemonic by default. Thus they will exit if parent thread exits which should probably be what most people want.
Fix optional parameter in delay_subscription. Thanks to @angelsanz.
delay_subscription. Thanks to @angelsanz.adapt_call in util.py which makes higher order functions
accept more forms of callables.timeflies_qt.py.Fix to preserve the original error message for exceptions #44, thanks to @hangtwenty
combine_latest(). Fixes #48.to_marbles() and from_marbles(). Available from module
rx.testing.marbles.share() as alias for publish().ref_count().Removed impl. of merge_observable and made it an alias of merge_all
merge_observable and made it an alias of merge_allfrom_().
Thanks to @hangtwenty.from_string() debug method.TkInterScheduler.schedule_periodic() thanks to @pillmuncher. #39zip_array to use zip instead.with_latest_from extension method #34. Thanks to @pillmuncher.Transducers via Observable.transduce()
Observable.transduce()adapt_call no longer requires the inspect moduleadapt_call
thanks to @succhiello.Fixed bug in ScheduledDisposable#dispose. Only dispose if not disposed
Pattern#_and. Should be Pattern#and_observer_from_notifier to Observer.from_notificationObservable#to_iterable()debounce instead of throttleselect_switch.Observable.when and Observable#and_BlockingObservableand operators for_each and to_iterableYour coding agent can read these notes before it upgrades. Set up the MCP server →