Learning Reactive Programming with Java 8

Chapter 3. Creating and Connecting Observables, Observers, and Subjects

RxJava's Observable instances are the building blocks of reactive applications, and this advantage of RxJava is beneficial. If we have a source Observable instance, we could chain logic to it and subscribe for the result. All we need is this initial Observable instance.

In the browser or in a desktop application, user input is already represented by events that we can handle and forward through Observable instances. But it would be great to turn all of our data changes or actions into Observable instances, not just user input. For example, when we read data from a file, it would be neat to look at every line read or every sequence of bytes as a message that can be emitted through ...