Pretty much all the Observable factories and operators you learned up to this point also apply to Flowable. On the factory side, there is Flowable.range(), Flowable.just(), Flowable.fromIterable(), and Flowable.interval(). Most of these implement backpressure for you, and 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 logically? Contemplate the fact that each emission is sensitively tied to the time it emits. If we slowed down Flowable.interval(), our emissions would no longer reflect time intervals and become misleading. Therefore, Flowable.interval() is one of those few cases in the standard API that can throw MissingBackpressureException the moment downstream requests backpressure. Here, if we emit every millisecond against a slow intenseCalculation() that occurs after observeOn(), we will get this error:
import...