- Refactored virtual time scheduling. Fixes #95. Thanks to @djarb
- Fixed Visual Studio project files and moved to ide folder.
- Remove timer operations from base
SchedulerBase
class. - Scheduler.now is now a property to align with Rx.NET
- Bugfix for periodic scheduling. Fixes #91. Thanks to @frederikaalund
- Demonize all threads in
TimeoutScheduler
. Fixes #90 - Enable subscription with duck-typed observer.
- Added new core module. Observable, Observer, Scheduler and Disposable are now ABCs.
- Synced backpressure with RxJS to fix #87
- Do not overwrite scheduler keyword arg. Fixes #85. Thanks to @rjayatilleka
- Added async iterator example.
- Added support for awaiting observables
- Fixed issue #83 with
int + datetime.datetime
in timer.py. Thanks to @AlexMost
- Fixes for TwistedScheduler raising AlreadyCalled error #78. Thanks to @mchen402 and @jcwilson.
- Use CurrentThreadScheduler as default for just/return_value. Fixes #76
- Added wxscheduler.py for use with wxPython applications thanks to @bosonogi
- Added eventletscheduler.py for use with Eventlet thanks to @jalandip
- Protect generators that are not thread safe. Fixes #71
- Threads are now daemonic by default. Thus they will exit if parent thread exits which should probably be what most people want.
- Fix for recursive scheduling, thanks to @smeder
- Fix for NewThreadScheduler. Now uses EventLoopScheduler to make sure scheduled actions by scheduled actions happens on the same thread.
- Uses shields.io to uniformize and fix the badges, thanks to @DavidJFelix
- Fix optional parameter in
delay_subscription
. Thanks to @angelsanz. - Simplified
adapt_call
inutil.py
which makes higher order functions accept more forms of callables. - Fix for Python 2.7 in
timeflies_qt.py
.
- Added Qt mainloop scheduler thanks to @jdreaver.
- Bugfix, wse
threading.RLock
instead ofthreading.Lock
sinceBehaviorSubject
may share lock with "child" operator at subscribe time. Fixes #50
- Fix to preserve the original error message for exceptions #44, thanks to @hangtwenty
- Fixed bug in
combine_latest()
. Fixes #48. - Added
to_marbles()
andfrom_marbles()
. Available from modulerx.testing.marbles
. - Added Getting Started IPython Notebook.
- Added
share()
as alias forpublish().ref_count()
. - Added error handling example at https://github.com/ReactiveX/RxPY/blob/master/examples/errors/failing.py
- Removed impl. of
merge_observable
and made it an alias ofmerge_all
- Bugfix for #40. Every subscription needs it's own iterator in
from_()
. Thanks to @hangtwenty. - Bugfix in
from_string()
debug method. - Added
TkInterScheduler.schedule_periodic()
thanks to @pillmuncher. #39 - Bugfix for #35. Refactored
zip_array
to usezip
instead. - AsyncIOScheduler now works with Python-2.7 and Trollius. Fixes #37 thanks to @hangtwenty.
- Added
with_latest_from
extension method #34. Thanks to @pillmuncher.
- 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.
- Fixed bug in ScheduledDisposable#dispose. Only dispose if not disposed
- Fixed typo in
Pattern#_and
. Should bePattern#and_
- Fixed bug. Replaced push with append in controlledsubject.py
- Refeactored
observer_from_notifier
toObserver.from_notification
- Added missing rx.linq.observable.blocking from setup.py
- Added missing rx.joins from setup.py
- Removed some non git files files that were added to the package by accident
- Added
Observable#to_iterable()
- Fixed examples. Use
debounce
instead ofthrottle
- Fixed wrong aliases for
select_switch
. - Added join patterns.
Observable.when
andObservable#and_
- Added
BlockingObservable
and operatorsfor_each
andto_iterable
- Started adding docstrings as reStructuredText in order for PyCharm to infer types. Operators will eventually be converted to new syntax
- Refactored operators to use C# like extensionmethods using function decorators
- More PEP8 alignment
- Python slicing and indexing of observables. Thus you can write xs[1:-1:2]
- Aligned backpressure with RxJS
- Renamed all
select()
tomap()
andwhere()
tomap()
from_
is now an alias forfrom_iterable
. Removedfrom_array
- Fixes for
select_many
/flat_map
. Selector may return iterable
- Made
ScheduledObserver
thread safe - Thread safe handling for
take_while
andgroup_join
- Removed dependecy on six (https://pythonhosted.org/six/)
- Added support for IronPython (by removing six)
- Aggregate is now an alias for reduce
- Aligning throttle type operator naming with RxJS and RxJava
- Added
throttle_last()
as alias forsample()
- Renamed
throttle()
todebounce()
and addedthrottle_with_timeout()
as alias - Renamed
any()
tosome()
- Simplified
sequence_equal()
- Bugfix for
take()
when no count given - Removed internal operator
final_value()
which did exactly the same aslast()
- Added
to_iterable()
as alias toto_list()
- Added
throttle_first()