These are chat archives for ReactiveX/RxJava

May 2016
James Moore
May 01 2016 20:11
Is there something like groupBy that creates a new observable every time the key changes?
May 01 2016 20:12
something like source.window(source.distinctUntillChanged(e -> key(e)))?
Or probably source.publish(o -> o.window(o.distinctUntilChanged(e -> key(e))))
James Moore
May 01 2016 20:15
i'll go look at those, tks
hadn't thought of feeding the same thing into window