These are chat archives for ReactiveX/RxJava

Oct 2018
Yannick Lecaillez
Oct 26 2018 09:17
I think i would go with bufferWhile().
I have the feeling that window() expect boundaries to be driven by external events (external meaning not related to the "windowed" stream)
David Karnok
Oct 26 2018 10:43
@ylecaillez It's a consequence of Rule 2.3 and verified by the TCK.
groupBy's groups must be consumed or else the sequence stalls for every group. Consequently, It won't cache all items indefinitely but it will cache group keys until the group is cancelled or the source ends.
Yannick Lecaillez
Oct 26 2018 13:50
oh yes, i missed that one. Thanks !