Learning RxJava - Second Edition

Using RxJava2-Extras and RxJava2Extensions

If you are interested in learning about additional operators beyond what RxJava provides, it may be worthwhile exploring the RxJava2-Extras and RxJava2Extensions libraries. While neither of these libraries is at a 1.0 version, useful operators, transformers, and Observable/Flowable factories are continually added as an ongoing project. Here is the configuration for Maven:

<dependency>    <groupId>com.github.davidmoten</groupId>    <artifactId>rxjava2-extras</artifactId>    <version>0.1.33</version></dependency>

Two useful operators are toListWhile() and collectWhile(). These will buffer emissions into a collection while they meet a certain condition. Because a BiPredicate passes both the collection and the ...