public abstract class RxJavaObservableExecutionHook
extends java.lang.Object
Observable execution with a
default no-op implementation.
See RxJavaPlugins or the RxJava GitHub Wiki for information on configuring plugins:
https://github.com/ReactiveX/RxJava/wiki/Plugins.
Note on thread-safety and performance:
A single implementation of this class will be used globally so methods on this class will be invoked concurrently from multiple threads so all functionality must be thread-safe.
Methods are also invoked synchronously and will add to execution time of the observable so all behavior should be fast. If anything time-consuming is to be done it should be spawned asynchronously onto separate worker threads.
| Constructor and Description |
|---|
RxJavaObservableExecutionHook() |
| Modifier and Type | Method and Description |
|---|---|
<T> Observable.OnSubscribe<T> |
onCreate(Observable.OnSubscribe<T> f)
Deprecated.
|
<T,R> Observable.Operator<? extends R,? super T> |
onLift(Observable.Operator<? extends R,? super T> lift)
Deprecated.
|
<T> java.lang.Throwable |
onSubscribeError(java.lang.Throwable e)
Deprecated.
|
<T> Subscription |
onSubscribeReturn(Subscription subscription)
Deprecated.
|
<T> Observable.OnSubscribe<T> |
onSubscribeStart(Observable<? extends T> observableInstance,
Observable.OnSubscribe<T> onSubscribe)
Deprecated.
|
@Deprecated public <T> Observable.OnSubscribe<T> onCreate(Observable.OnSubscribe<T> f)
Observable.unsafeCreate(OnSubscribe)
This can be used to decorate or replace the onSubscribe function or just perform extra
logging, metrics and other such things and pass through the function.
T - the value typef - original Observable.OnSubscribe<T> to be executedObservable.OnSubscribe<T> function that can be modified, decorated, replaced or just
returned as a pass through@Deprecated public <T> Observable.OnSubscribe<T> onSubscribeStart(Observable<? extends T> observableInstance, Observable.OnSubscribe<T> onSubscribe)
Observable.subscribe(rx.Subscriber) is about to be executed.
This can be used to decorate or replace the onSubscribe function or just perform extra
logging, metrics and other such things and pass through the function.
T - the value typeobservableInstance - the parent observable instanceonSubscribe - original Observable.OnSubscribe<T> to be executedObservable.OnSubscribe<T> function that can be modified, decorated, replaced or just
returned as a pass through@Deprecated public <T> Subscription onSubscribeReturn(Subscription subscription)
Observable.subscribe(rx.Subscriber) with returned
Subscription.
This can be used to decorate or replace the Subscription instance or just perform extra logging,
metrics and other such things and pass through the subscription.
T - the value typesubscription - original SubscriptionSubscription subscription that can be modified, decorated, replaced or just returned as a
pass through@Deprecated public <T> java.lang.Throwable onSubscribeError(java.lang.Throwable e)
Observable.subscribe(Subscriber) with thrown Throwable.
This is not errors emitted via Observer.onError(Throwable) but exceptions thrown when
attempting to subscribe to a Func1<Subscriber<T>, Subscription>.
T - the value typee - Throwable thrown by Observable.subscribe(Subscriber)@Deprecated public <T,R> Observable.Operator<? extends R,? super T> onLift(Observable.Operator<? extends R,? super T> lift)
Observable and the return value is used as the lifted function
This can be used to decorate or replace the Observable.Operator instance or just perform extra
logging, metrics and other such things and pass through the onSubscribe.
T - the upstream's value type (input)R - the downstream's value type (output)lift - original Observable.Operator<R, T>Observable.Operator<R, T> function that can be modified, decorated, replaced or just
returned as a pass through