Reactive Everything: Long Operations

Let’s make everything reactive

From the previous examples, we’ve seen that we can wrap any object in an Observable and jump between non-reactive and reactive states using .blockingX() operators. In addition, we can delay execution of an operation by wrapping it in a .fromCallable() or .defer() Observable creation method. Using these constructs, we can start converting areas of an Android app to be reactive.

Long operations

A good place to start using RxJava is whenever we have a process that takes a while to compute, for example, network calls, disk reads and writes, bitmap processing, and so on.