The Observable Contract

The observable contract defines the fundamental behaviour under which Observable work. One must go through them at least once to have a better understanding about its working.

Source:

I am adding a summary of key concepts:

Notifications

· Observable make zero or more OnNext notifications, each representing a single emitted item, followed by either OnCompleted or OnError (Must contain cause of the error) notification, but not both, after which it will not issue any further notification.

· It is proper for an Observable to issue no notifications (Never terminates), to issue only an OnCompleted or an OnError notification, or to issue only OnNext notifications (Never terminates). But before it terminates it must first issue either an OnCompleted or OnError notification to all the observers that are subscribed to it.

· Observables must issue notifications to observers serially (not in parallel). They may issue these notifications from different threads, but there must be a formal happens-before relationship between the notifications.

· It is not guaranteed, that the Observable will issue no notifications to the observer after an observer issues it an Unsubscribe notification.

· When an Observable issues an OnError or OnComplete notification to its observers, this ends the subscription. Observers do not need to issue an Unsubscribe notification to end subscriptions that are ended by the Observable in this way.

· If a second observer subscribes to an Observable that is already emitting items to a first observer, it is up to the Observable whether it will thenceforth emit the same items to each observer, or whether it will replay the complete sequence of items from the beginning to the second observer, or whether it will emit a wholly different sequence of items to the second observer. There is no general guarantee that two observers of the same Observable will see the same sequence of items.

Backpressure

· Backpressure is optional; not all ReactiveX implementations include backpressure, and in those that do, not all Observables or operators honor backpressure. An Observable may implement backpressure if it detects that its observer implements Request notifications and understands OnSubscribe notifications.

· If an Observable implements backpressure and its observer employs backpressure, the Observable will not begin to emit items to the observer immediately upon subscription. Instead, it will issue an OnSubscribe notification to the observer.

· At any time after it receives an OnSubscribe notification, an observer may issue a Request notification to the Observable it has subscribed to. This notification requests a particular number of items. The Observable responds to such a Request by emitting no more items to the observer than the number of items the observer requests. However the Observable may, in addition, issue an OnCompleted or OnError notification, and it may even issue such a notification before the observer requests any items at all.

· An Observable that does not implement backpressure should respond to a Request notification from an observer by issuing an OnError notification that indicates that backpressure is not supported.

· Requests are cumulative. For example, if an observer issues three Request notifications to an Observable, for 3, 5, and 10 items respectively, that Observable may emit as many as 18 items to the observer, no matter when those Request notifications arrived relative to when the Observable emitted items in response.

· If the Observable produces more items than the observer requests, it is up to the Observable whether it will discard the excess items, store them to emit at a later time, or use some other strategy to deal with the overflow.

Show your support

Clapping shows how much you appreciated Neeraj Nayan’s story.