-
public abstract class RxJavaObservableExecutionHookAbstract ExecutionHook with invocations at different lifecycle points of 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.
-
-
Method Summary
Modifier and Type Method Description <T> Observable.OnSubscribe<T>onCreate(Observable.OnSubscribe<T> f)<T> Observable.OnSubscribe<T>onSubscribeStart(Observable<out T> observableInstance, Observable.OnSubscribe<T> onSubscribe)<T> SubscriptiononSubscribeReturn(Subscription subscription)<T> ThrowableonSubscribeError(Throwable e)<T, R> Observable.Operator<out R, out Object>onLift(Observable.Operator<out R, out Object> lift)Invoked just as the operator functions is called to bind two operations together into a new Observable and the return value is used as the lifted function s * logging, metrics and other such things and pass through the onSubscribe. -
-
Method Detail
-
onCreate
@Deprecated() <T> Observable.OnSubscribe<T> onCreate(Observable.OnSubscribe<T> f)
-
onSubscribeStart
@Deprecated() <T> Observable.OnSubscribe<T> onSubscribeStart(Observable<out T> observableInstance, Observable.OnSubscribe<T> onSubscribe)
-
onSubscribeReturn
@Deprecated() <T> Subscription onSubscribeReturn(Subscription subscription)
-
onSubscribeError
@Deprecated() <T> Throwable onSubscribeError(Throwable e)
-
onLift
@Deprecated() <T, R> Observable.Operator<out R, out Object> onLift(Observable.Operator<out R, out Object> lift)
Invoked just as the operator functions is called to bind two operations together into a new Observable and the return value is used as the lifted function
s * logging, metrics and other such things and pass through the onSubscribe.
- Parameters:
lift- returned as a pass through
-
-
-
-