Achieving True Concurrency
Learn to implement true concurrency with the help of .flatMap().
We'll cover the following...
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 ...