Spring 5.0 Projects

Observer event calls

What we discussed so far is very high-level information about how we can use Observable in RxJava. It basically pushes (emits) the items (data or events) of a given type through a series of operators (if defined) until it reaches  Observer. Let's dig into more details to understand which mechanism works under the hood between this interaction and how RxJava complies with Reactive Streams specifications.

Observable interacts with Observers through the following event calls:

• onNext: This is the call from where data/events are being sent, one at a time, down to all registered Observers.
• onComplete: This event is used to signal completion of communication to all. 
•  Observers: It simply denotes no more onNext calls happen. ...