We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
Have a question about this project? Sign up for a free GitHub account to open an issue and contact its maintainers and the community.
By clicking “Sign up for GitHub”, you agree to our terms of service and privacy statement. We’ll occasionally send you account related emails.
Already on GitHub? Sign in to your account
merge
I am playing with RxRuby, but I'm not sure that behavior of merge function is as expected.
Here is test code:
require './lib/rx' count_stream = RX::Observable.range(1, 5) fizz_stream = count_stream.select {|x| x % 3 == 0}.map {'Fizz'} otherwise_stream = count_stream.select {|x| x % 3 != 0} merged_stream = RX::Observable.merge(fizz_stream, otherwise_stream) merged_stream.subscribe {|x| puts x}
I think merge function of Rx keeps event order (RxMarbles ), so I expect the code outputs 1 2 Fizz 4 5, but the result is:
Rx
1 2 Fizz 4 5
1 Fizz 2 4 5
Is this behavior expected?
The text was updated successfully, but these errors were encountered:
No branches or pull requests
I am playing with RxRuby, but I'm not sure that behavior of
merge
function is as expected.Here is test code:
I think
merge
function ofRx
keeps event order (RxMarbles ), so I expect the code outputs1 2 Fizz 4 5
, but the result is:Is this behavior expected?
The text was updated successfully, but these errors were encountered: