Skip to content

rxdogtag / com.uber.rxdogtag / ObserverHandler

ObserverHandler

interface ObserverHandler

This interface can be used to further decorate or unpack custom subscribers/observers as needed.

Example use cases:

  • Unpacking custom observers to yield their underlying delegate observers or behavior.
  • Decorating observers with custom runtime behavior.

Note: The observer returned here will NOT be used for anything other than determining if there is custom error handling.

Functions

Name Summary
handle open fun handle(flowable: Flowable!, subscriber: Subscriber!): Subscriber!
Callbacks to handle Flowable and Subscriber.open fun handle(observable: Observable!, observer: Observer!): Observer!
Callbacks to handle Observable and Observer.open fun handle(maybe: Maybe!, observer: MaybeObserver!): MaybeObserver!
Callbacks to handle Maybe and MaybeObserver.open fun handle(single: Single!, observer: SingleObserver!): SingleObserver!
Callbacks to handle Single and SingleObserver.open fun handle(completable: Completable!, observer: CompletableObserver!): CompletableObserver!
Callbacks to handle Completable and CompletableObserver.