rxdogtag2

Interface ObserverHandler

public 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 LambdaConsumerIntrospection 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.

Method Summary

Modifier and Type	Method and Description
default io.reactivex.rxjava3.core.CompletableObserver	handle(io.reactivex.rxjava3.core.Completable completable, io.reactivex.rxjava3.core.CompletableObserver observer) Callbacks to handle Completable and CompletableObserver.
default org.reactivestreams.Subscriber	handle(io.reactivex.rxjava3.core.Flowable flowable, org.reactivestreams.Subscriber subscriber) Callbacks to handle Flowable and Subscriber.
default io.reactivex.rxjava3.core.MaybeObserver	handle(io.reactivex.rxjava3.core.Maybe maybe, io.reactivex.rxjava3.core.MaybeObserver observer) Callbacks to handle Maybe and MaybeObserver.
default io.reactivex.rxjava3.core.Observer	handle(io.reactivex.rxjava3.core.Observable observable, io.reactivex.rxjava3.core.Observer observer) Callbacks to handle Observable and Observer.
default io.reactivex.rxjava3.core.SingleObserver	handle(io.reactivex.rxjava3.core.Single single, io.reactivex.rxjava3.core.SingleObserver observer) Callbacks to handle Single and SingleObserver.

Method Detail

handle

default org.reactivestreams.Subscriber handle(io.reactivex.rxjava3.core.Flowable flowable,
                                              org.reactivestreams.Subscriber subscriber)

Callbacks to handle Flowable and Subscriber.

Parameters:

flowable - the source flowable.

subscriber - the source subscriber.

Returns:

possible decorated or unpacked observer.

handle

default io.reactivex.rxjava3.core.Observer handle(io.reactivex.rxjava3.core.Observable observable,
                                                  io.reactivex.rxjava3.core.Observer observer)

Callbacks to handle Observable and Observer.

Parameters:

observable - the source observable.

observer - the source observer.

Returns:

possible decorated or unpacked observer.

handle

default io.reactivex.rxjava3.core.MaybeObserver handle(io.reactivex.rxjava3.core.Maybe maybe,
                                                       io.reactivex.rxjava3.core.MaybeObserver observer)

Callbacks to handle Maybe and MaybeObserver.

Parameters:

maybe - the source maybe.

observer - the source observer.

Returns:

possible decorated or unpacked observer.

handle

default io.reactivex.rxjava3.core.SingleObserver handle(io.reactivex.rxjava3.core.Single single,
                                                        io.reactivex.rxjava3.core.SingleObserver observer)

Callbacks to handle Single and SingleObserver.

Parameters:

single - the source single.

observer - the source observer.

Returns:

possible decorated or unpacked observer.

handle

default io.reactivex.rxjava3.core.CompletableObserver handle(io.reactivex.rxjava3.core.Completable completable,
                                                             io.reactivex.rxjava3.core.CompletableObserver observer)

Callbacks to handle Completable and CompletableObserver.

Parameters:

completable - the source completable.

observer - the source observer.

Returns:

possible decorated or unpacked observer.