Mastering Kotlin

Key concepts in RxJava

ReactiveX and RxJava, by extension, are built upon several foundational components and concepts. These are the building blocks for all other operators and patterns that make ReactiveX so powerful, popular, and complex.

The following snippet illustrates how Rx Observables can be chained together with operators:

loadAsyncStudentData()  .observeOn(Schedulers.io())  .filter({ student -> return student.getAge() > 17 })  .sort()  .first(5)  .subscribe({     // handle output  })

By doing so, we make asynchronous programming a much easier task to read, write, and debug.