...

/

Achieving True Concurrency

Achieving True Concurrency

Learn to implement true concurrency with the help of .flatMap().

So far, we have looked at ways to introduce multithreading through the use of Schedulers along with the .subscribeOn() and .observeOn() operators. To achieve true concurrency, however, these operators alone are not sufficient.

The basics of true concurrency

If you noticed in our example of using .subscribeOn(), events received from upstream are not processed on separate threads. All emissions were executed on the same thread, RxCachedThreadScheduler-1. To achieve true concurrency, we need the help of ...