Design Patterns and Best Practices in Java

The subscribe operator

These are the methods used by a subscriber to consume the emissions and notifications from an Observable, such as onNext, onError, and onCompleted. The Observable methods used for subscribing are:

• blockingForEach: Consumes each item emitted by this Observable and blocks until the Observable completes.
• blockingSubscribe: Subscribes to the Observable and consumes events on the current thread.
• forEachWhile: Subscribes to the Observable and receives notifications for each element until the onNext Predicate returns false.
• forEach: Subscribes to the Observable and receives notifications for each element.
• subscribe: Subscribes the given observer to this Observable. The observer can be given as callbacks, observer implementations, ...