RxRuby
RxRuby copied to clipboard
Reactive Extensions for Ruby
how can I install by gem?
The project has stop developing for a while. Does the develop team keep update this project in the future?
`Observable#subscribe_on` incorrectly referred to the latter, but the class was actually called the former. Looking at similar implementation it seems to me to be more in line with a subscription...
Fixes ReactiveX/RxRuby#107.
Fix, what I assume is, a typo. Hope the added test is inline with existing ones, since I haven't had the time to get into the tests.
The following code generates this traceback: ``` /var/lib/gems/2.1.0/gems/rx-0.0.3/lib/rx/subjects/behavior_subject.rb:80:in `block in on_next': private method `check_unsubscribed' called for # (NoMethodError) from /var/lib/gems/2.1.0/gems/rx-0.0.3/lib/rx/subjects/behavior_subject.rb:79:in `synchronize' from /var/lib/gems/2.1.0/gems/rx-0.0.3/lib/rx/subjects/behavior_subject.rb:79:in `on_next' from behavior_example.rb:3:in ` ``` ``` require...
RxRuby should implement the [ReactiveX Sample operator](http://reactivex.io/documentation/operators/sample.html). I've found Sample in the Rx.NET library useful in my .NET projects and I find myself needing it in my current Ruby project....
When no block is specified, the `combine_latest` operator should combine its two streams into an array (a pair of elements). Currently, `combine_latest` errors when no block is specified: ```ruby require...
There seems to be a bug in the Ruby implementation of start_with. The two examples below, one written using RxRb, the other using RxPy, construct the same observable, emitting a...