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.
Observable.range(1, Integer.MAX_VALUE)(or whatever max expected length you might have)?
locationemits every second. Some sensors emit fast and usually result in a case that window will not be empty. However, some sensors emit less frequently. This results in an empty window. An empty window then results in
Observable.zipnot emitting until the slow sensor emits again
withLatestFromwould have solved it but it looks like RxJava only implemented combination with only one observable and not variable arguments like RxJS has :(