Learning RxJava

An example that needs backpressure

When you add concurrency operations to an Observable chain (particularly observeOn(), parallelization, and operators such as delay()), the operation become asynchronous. This means hat multiple parts of the Observable chain can be processing emissions at a given time, and producers can outpace consumers as they are now operating on different threads. An emission is no longer strictly being handed downstream one at a time from the source all the way to the Observer before starting the next one. This is because once an emission hits a different Scheduler through observeOn() (or other concurrent operators), the source is no longer in charge of pushing that emission to the Observer. Therefore, the source will ...