Learning RxJava

Using Flowable.create() and BackpressureStrategy

Leveraging Flowable.create() to create a Flowable feels much like Observable.create(), but there is one critical difference; you must specify a BackpressureStrategy as a second argument. This enumerable type does not by any means provide magic implementations of backpressure support. As a matter of fact, this simply supports backpressure by caching or dropping emissions or not implementing backpressure at all.

Here, we use Flowable.create() to create a Flowable, but we provide a second BackpressureStrategy.BUFFER argument to buffer the emissions before they are backpressured:

 import io.reactivex.BackpressureStrategy; import io.reactivex.Flowable; import io.reactivex.schedulers.Schedulers; ...