Scala Reactive Programming

Subscriber

This is an extension of the Observer trait, which adds the following two new features:

• Subscription handling: This has the implementation of the unsubscribe(), isUnsubscribed(), and add() methods to take care of the handling subscription process.
• Back-pressure handling: This has the implementation of the onStart() and request() methods to take care of the handling back-pressure process.

Once a Subscriber makes a call to an Observable.subscribe() method and the subscription is done, the Observable calls the Subscriber.onNext() method to provide notifications to that Subscriber. The asynchronous data stream processing may either finish it successfully or have some errors. If it's done successfully, Observable will make a call to ...