Transforming Observables

These are the operators that transform items emitted by an Observable.

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, or subtypes of the abstract io.reactivex.subscribers.DefaultSubscriber<T> class.

The buffer operator

The buffer method is used to create bundles of a given...