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.
.never(), but right now your source wont ever complete even when both
datahave completed right? That's a bit of a leak.
@ardoramor Something like
Observable.zip( location, sensor1.window(location).flatMap(window.reduce(...)), sensor2.window(location).flatMap(window.reduce(...)), (location, sensor1, sensor2) -> ...)
Might be a good idea to add a little extra logic that ensures every window as at least some data, like the previouse value if the current window is empty.