These are chat archives for ReactiveX/RxJava
RxJava – Reactive Extensions for the JVM – a library for composing asynchronous and event-based programs using observable sequences for the Java VM.
Completable.amb(), the interleaving works just fine.
setDisposabletogether will cancel/dispose the previous resource. Use a CompositeDisposable, add resources to it and then call
flatMapdoesn't guarantee interleaving and otherwise it depends on the emission frequency of the sources. An attempt at interleaving two
range()will not work with
flatMap. There is an extension operator that lets you merge streams in a round-robin fashion which can result a better interleaving, still no 100% guarantee.
@tim4dev I see two problems:
1) you didn't initialize [mDisposable]
I apologize for that. But this code was commented out.
I've tried a lot of things really.
Here is the actual code: https://gist.github.com/tim4dev/e7b207ff85f1798bd10fe6f6b2f0514c