June 2017
Intermediate to advanced
400 pages
8h 44m
English
If you are provided a Flowable that has no backpressure implementation (including ones derived from Observable), you can apply BackpressureStrategy using onBackpressureXXX() operators. These also provide a few additional configuration options. This can be helpful if, for example, you have a Flowable.interval() that emits faster than consumers can keep up. Flowable.interval() cannot be slowed down at the source because it is time-driven, but we can use an onBackpressureXXX() operator to proxy between it and the downstream. We will use Flowable.interval() for these examples, but this can apply to any Flowable that does not have backpressure implemented.
Sometimes, Flowable may simply be configured with ...
Read now
Unlock full access