Summary

We used lots of operators to create, transform, and merge an Observable in many ways, keeping in mind RxJava supports asynchronous Reactive Programming. We expected the operators provided by the RxJava library to be using multithreading internally. However, in the first half of this chapter, we proved the operators are not using multiple threads. They use a single thread to execute the complete process of the creation of an Observable emitting the items, the processing of the emitted items, and then their subscription. In the second half, we discussed concurrency, how to achieve it, and the difference between concurrency and parallelism. We know creating threads and handling processes using the created threads adds overhead to the developers. We now need to schedule the process of emission, transformation, and subscription on different threads. RxJava provides a Scheduler...