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.
scanthe original source instead of
collect, and sample the result.
output, so you can just used
reducedis the same as
outputto me, either. The output of each window is a Map. The final step is merging the map emitted by the current window with the map from the previous window.
scanemit all intermediate values also. Not sure if that bode well if you are emitting the same mutable datatype each time.
return output;. If i understand that correctly that means that in
.subscribe(reduced -> ...),
outputvariable returned by map.