-
Book Overview & Buying
-
Table Of Contents
Learning RxJava
By :
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 Schedulerat 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 even if they call the dispose() method.
It is important to note that when you start playing with concurrency, you...
Change the font size
Change margin width
Change background colour