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 next T item as a lambda expression, you can use this to buffer items but cut off the...