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.
I'm struggling to find an example where we can use
Flowable.window(boundaryIndicatorSupplier). My goal is to create windows with groups of elements with same id.
Flowable.just(new MyObject(1, "X"), new MyObject(1, "Y"), new MyObject(1, "Z"), new MyObject(2, "A"), new MyObject(2, "B") .window( <boundary to create new window when MyObject changes from 1 to 2>)
(note, I want to do this in sorted flowables where I know when a "group" ends/starts (id changes from one value to the next))
window(boundary)would be able to create one list at a time, when the boundary condition is valid