Conditional operators

Conditional operators emit or transform Observable conditionally. This allows a control flow to be organized and the path of execution to be determined, which is especially important for adding decision-making ability to your program.

takeWhile() and skipWhile()

Another variant of the take() operator is the takeWhile() operator, which takes emissions while a condition derived from each emission is true. The following example will keep taking emissions while emissions are less than 5. The moment it encounters one that is not, it will generate the onComplete event and dispose of the used resources:

import io.reactivex.rxjava3.core.Observable;

public class Ch3_01 {
    public static void main(String[] args...