It extends the observer pattern to support sequences of data/events and adds operators that allow you to compose sequences together declaratively while abstracting away concerns about things like low-level threading, synchronization, thread-safety, and concurrent data structures.
Flowable.groupByeviction logic double decrement and hang. (#6975)
Flowable.groupBycancellation/cleanup/eviction race hangs. (#6979)
- Disable fusion on the groups of
Flowable.groupByeviction-completion-replenishment problems. (#6988)
- Removed unnecessary
upstream.cancel()call for casually finished upstream sequences. (#6992)