Scala Reactive Programming

Understanding the Observable

It is the Observable interface that implements the Reactive pattern. It has the subscribe() method to subscribe the Observer or Subscriber to send items and notifications to them:

observable.subscribe(observer)   // To subscribe an Observer 
observable.subscribe(subscriber) // To subscribe an Subscriber 

An Observable[T] instance is responsible for accepting all subscriptions and notifying all observers and subscribers for that item. The subscribe() method does the following:

• It stores a reference to the Observer in a Collection object, such as a List[T] object.
• This will return a reference to the Subscription interface. This will enable the Observers to unsubscribe that is, to stop receiving items and notifications ...