Learning RxJava - Second Edition

Understanding Flowable and Subscriber

Pretty much all the Observable factories and operators you learned up to this point also apply to Flowable. On the factory side, there are Flowable.range(), Flowable.just(), Flowable.fromIterable(), and Flowable.interval(). Most of these sources support backpressure. Their usage is generally the same as the Observable equivalent.

However, consider Flowable.interval(), which pushes time-based emissions at fixed time intervals. Can this be backpressured? Contemplate the fact that each emission is tied to the time it emits. If we slowed down Flowable.interval(), our emissions would no longer reflect the specified time interval and become misleading. Therefore, Flowable.interval() is one of those few cases ...