This is an improvement and bugfix release.

Improvements

• Add fork_join operator #533
• Allow AsyncIOThreadSafeScheduler to schedule on its own AsyncIO event loop #567

Fixes

• Fix InvalidStateError in to_future #529
• Complete as soon as any source completed In zip #525
• Fix delay_with_mapper subscription #547
• Fix scheduler forwarding in delay operator #555

Other

• Do not use pytest-runner #522

This is a bugfix and performance improvment release.

Fixes:

• Explicitly catch asyncio.CancelledError #498
• Do not used start_with in reduce #488
• Fix race condition in zip operator #505
• Fix GEventScheduler deadlock #519

Performance:

• Drop reference to cached items asap in to_xxx #509

Other:

• Fixed several errors in documentation
• Fixed mypy support in sdist #515

This is a bugfix and enhancement release. The principal evolutions are:

• Fixed flat_map with mapper returning an asyncio Future #457
• Fixed await on Observable that schedules later #456
• Fixed scheduler forwading in several operators #476 #492 #493
• Fixed concat: subscribe scheduler not forwarded + sources iterable exhaustion #486
• Fixed missing default scheduler in timer operator #481
• Fixed concat_with_iterable: subscribe scheduler is not forwarded #495
• Added subject mapper to group_by and group_by_until #467
• Many small fixes on the documentation

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

• Transducers via Observable.transduce()
• adapt_call no longer requires the inspect module
• Support callable instance, instance method, and class method for adapt_call thanks to @succhiello.
• Added example using concurrent futures for compute-intensive task parallelization, thanks to @38elements.
• Got chess example working again under Python 2.7 thansks to @enobayram.
• Added example for async generator.
• Many PEP 8 fixes.

First stable release of RxPY.

• Aligning throttle type operator naming with RxJS and RxJava
• Added throttle_last() as alias for sample()
• Renamed throttle() to debounce() and added throttle_with_timeout() as alias
• Renamed any() to some()
• Simplified sequence_equal()
• Bugfix for take() when no count given
• Removed internal operator final_value() which did exactly the same as last()
• Added to_iterable() as alias to to_list()
• Added throttle_first()