1
2
3
4
5
6
7
8
9
10
11
12
13
14
15
16
17
18
19
20
21
22
23
24
25
26
27
28
29
30
31
32
33
34
35
36
37
38
39
40
41
42
43
44
45
46
47
48
49
50
51
52
53
54
55
56
57
58
59
60
61
62
63
64
65
66
67
68
69
70
71
72
73
74
75
76
77
78
79
80
81
82
83
84
85
86
87
88
89
90
91
92
93
94
95
96
97
98
99
100
101
102
103
104
105
106
107
108
109
110
111
112
113
114
115
116
117
118
119
120
121
122
123
124
125
126
127
128
129
130
131
132
133
134
135
136
137
138
139
140
141
142
143
144
145
146
147
|
# Changes
## 2.0.0-alpha
- Extension methods and extension class methods have been removed. This
makes it much easier for editors and IDEs to validate the code and
perform code completion.
- Python 3.6+ only with type hints
- Google docstring style.
## 1.5.0
- 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
## 1.2.6
- Fixes for TwistedScheduler raising AlreadyCalled error #78. Thanks to
@mchen402 and @jcwilson.
- Use CurrentThreadScheduler as default for just/return_value. Fixes #76
## 1.2.5
- 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
## 1.2.4
- 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
## 1.2.3
- Fix optional parameter in `delay_subscription`. Thanks to @angelsanz.
- Simplified `adapt_call` in `util.py` which makes higher order functions
accept more forms of callables.
- Fix for Python 2.7 in `timeflies_qt.py`.
## 1.2.2
- Added Qt mainloop scheduler thanks to @jdreaver.
- Bugfix, wse `threading.RLock` instead of `threading.Lock` since
`BehaviorSubject` may share lock with "child" operator at subscribe
time. Fixes #50
## 1.2.1
- Fix to preserve the original error message for exceptions #44, thanks
to @hangtwenty
- Fixed bug in `combine_latest()`. Fixes #48.
- Added `to_marbles()` and `from_marbles()`. Available from module
`rx.testing.marbles`.
- Added [Getting Started](https://github.com/ReactiveX/RxPY/blob/master/notebooks/Getting%20Started.ipynb)
IPython Notebook.
- Added `share()` as alias for `publish().ref_count()`.
- Added error handling example at https://github.com/ReactiveX/RxPY/blob/master/examples/errors/failing.py
## 1.2.0
- Removed impl. of `merge_observable` and made it an alias of `merge_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 use `zip` 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.
## 1.1.0
- 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.
## 1.0.0
- Fixed bug in ScheduledDisposable#dispose. Only dispose if not disposed
- Fixed typo in `Pattern#_and`. Should be `Pattern#and_`
- Fixed bug. Replaced push with append in controlledsubject.py
- Refeactored `observer_from_notifier` to `Observer.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 of `throttle`
- Fixed wrong aliases for `select_switch`.
- Added join patterns. `Observable.when` and `Observable#and_`
- Added `BlockingObservable`and operators `for_each` and `to_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
## 0.15
- Python slicing and indexing of observables. Thus you can write xs[1:-1:2]
- Aligned backpressure with RxJS
- Renamed all `select()` to `map()` and `where()` to `map()`
- `from_` is now an alias for `from_iterable`. Removed `from_array`
- Fixes for `flat_map`/`flat_map`. Selector may return iterable
## 0.14
- Made `ScheduledObserver` thread safe
- Thread safe handling for `take_while` and `group_join`
- Removed dependecy on six (https://pythonhosted.org/six/)
- Added support for IronPython (by removing six)
- Aggregate is now an alias for reduce
## 0.13
- 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()`
|
