public interface ObserverHandler
Example use cases:
LambdaConsumerIntrospection behavior.
Note: The observer returned here will NOT be used for anything other than determining if there is custom error handling.
| 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. |
default org.reactivestreams.Subscriber handle(io.reactivex.rxjava3.core.Flowable flowable,
org.reactivestreams.Subscriber subscriber)
Flowable and Subscriber.flowable - the source flowable.subscriber - the source subscriber.default io.reactivex.rxjava3.core.Observer handle(io.reactivex.rxjava3.core.Observable observable,
io.reactivex.rxjava3.core.Observer observer)
Observable and Observer.observable - the source observable.observer - the source observer.default io.reactivex.rxjava3.core.MaybeObserver handle(io.reactivex.rxjava3.core.Maybe maybe,
io.reactivex.rxjava3.core.MaybeObserver observer)
Maybe and MaybeObserver.maybe - the source maybe.observer - the source observer.default io.reactivex.rxjava3.core.SingleObserver handle(io.reactivex.rxjava3.core.Single single,
io.reactivex.rxjava3.core.SingleObserver observer)
Single and SingleObserver.single - the source single.observer - the source observer.default io.reactivex.rxjava3.core.CompletableObserver handle(io.reactivex.rxjava3.core.Completable completable,
io.reactivex.rxjava3.core.CompletableObserver observer)
Completable and CompletableObserver.completable - the source completable.observer - the source observer.