Summary

This was probably our most intense chapter yet, but it provides a turning point in your proficiency as an RxJava developer as well as a master of concurrency! We covered the different Schedulers available in RxJava as well as ones available in other libraries such as RxJavaFX and RxAndroid. The subscribeOn() operator is used to suggest to the upstream in an Observable chain which Scheduler to push emissions on.  The observeOn()will switch emissions to a different Scheduler at that point in the Observable chain and use that Scheduler downstream. You can use these two operators in conjunction with flatMap() to create powerful parallelization patterns so you can fully utilize your multi-CPU power. We finally covered unsubscribeOn(), which helps us specify a different Scheduler to dispose operations on, preventing subtle hang-ups on threads we want to keep free and available...