public final class

RxJavaPlugins

extends Object
java.lang.Object
   ↳ io.reactivex.plugins.RxJavaPlugins

Class Overview

Utility class to inject handlers to certain standard RxJava operations.

Summary

Public Methods
static Scheduler createComputationScheduler(ThreadFactory threadFactory)
Create an instance of the default Scheduler used for computation() except using threadFactory for thread creation.
static Scheduler createIoScheduler(ThreadFactory threadFactory)
Create an instance of the default Scheduler used for io() except using threadFactory for thread creation.
static Scheduler createNewThreadScheduler(ThreadFactory threadFactory)
Create an instance of the default Scheduler used for newThread() except using threadFactory for thread creation.
static Scheduler createSingleScheduler(ThreadFactory threadFactory)
Create an instance of the default Scheduler used for single() except using threadFactory for thread creation.
static Function<? super Scheduler, ? extends Scheduler> getComputationSchedulerHandler()
Returns the current hook function.
static Consumer<? super Throwable> getErrorHandler()
Returns the a hook consumer.
static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitComputationSchedulerHandler()
Returns the current hook function.
static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitIoSchedulerHandler()
Returns the current hook function.
static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitNewThreadSchedulerHandler()
Returns the current hook function.
static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitSingleSchedulerHandler()
Returns the current hook function.
static Function<? super Scheduler, ? extends Scheduler> getIoSchedulerHandler()
Returns the current hook function.
static Function<? super Scheduler, ? extends Scheduler> getNewThreadSchedulerHandler()
Returns the current hook function.
static BooleanSupplier getOnBeforeBlocking()
Returns the current blocking handler or null if no custom handler is set.
static Function<? super Completable, ? extends Completable> getOnCompletableAssembly()
Returns the current hook function.
static BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> getOnCompletableSubscribe()
Returns the current hook function.
static Function<? super ConnectableFlowable, ? extends ConnectableFlowable> getOnConnectableFlowableAssembly()
Returns the current hook function.
static Function<? super ConnectableObservable, ? extends ConnectableObservable> getOnConnectableObservableAssembly()
Returns the current hook function.
static Function<? super Flowable, ? extends Flowable> getOnFlowableAssembly()
Returns the current hook function.
static BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> getOnFlowableSubscribe()
Returns the current hook function.
static Function<? super Maybe, ? extends Maybe> getOnMaybeAssembly()
Returns the current hook function.
static BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver> getOnMaybeSubscribe()
Returns the current hook function.
static Function<? super Observable, ? extends Observable> getOnObservableAssembly()
Returns the current hook function.
static BiFunction<? super Observable, ? super Observer, ? extends Observer> getOnObservableSubscribe()
Returns the current hook function.
static Function<? super ParallelFlowable, ? extends ParallelFlowable> getOnParallelAssembly()
Returns the current hook function.
static Function<? super Single, ? extends Single> getOnSingleAssembly()
Returns the current hook function.
static BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> getOnSingleSubscribe()
Returns the current hook function.
static Function<? super Runnable, ? extends Runnable> getScheduleHandler()
Returns the current hook function.
static Function<? super Scheduler, ? extends Scheduler> getSingleSchedulerHandler()
Returns the current hook function.
static Scheduler initComputationScheduler(Callable<Scheduler> defaultScheduler)
Calls the associated hook function.
static Scheduler initIoScheduler(Callable<Scheduler> defaultScheduler)
Calls the associated hook function.
static Scheduler initNewThreadScheduler(Callable<Scheduler> defaultScheduler)
Calls the associated hook function.
static Scheduler initSingleScheduler(Callable<Scheduler> defaultScheduler)
Calls the associated hook function.
static boolean isFailOnNonBlockingScheduler()
Returns true if the blockingX operators fail with an IllegalStateException on a non-blocking scheduler such as computation or single.
static boolean isLockdown()
Returns true if the plugins were locked down.
static void lockdown()
Prevents changing the plugins from then on.
static <T> Single<T> onAssembly(Single<T> source)
Calls the associated hook function.
static <T> Observable<T> onAssembly(Observable<T> source)
Calls the associated hook function.
static <T> ConnectableFlowable<T> onAssembly(ConnectableFlowable<T> source)
Calls the associated hook function.
static <T> Flowable<T> onAssembly(Flowable<T> source)
Calls the associated hook function.
static <T> ParallelFlowable<T> onAssembly(ParallelFlowable<T> source)
Calls the associated hook function.
static <T> Maybe<T> onAssembly(Maybe<T> source)
Calls the associated hook function.
static Completable onAssembly(Completable source)
Calls the associated hook function.
static <T> ConnectableObservable<T> onAssembly(ConnectableObservable<T> source)
Calls the associated hook function.
static boolean onBeforeBlocking()
Called before an operator attempts a blocking operation such as awaiting a condition or signal and should return true to indicate the operator should not block but throw an IllegalArgumentException.
static Scheduler onComputationScheduler(Scheduler defaultScheduler)
Calls the associated hook function.
static void onError(Throwable error)
Called when an undeliverable error occurs.
static Scheduler onIoScheduler(Scheduler defaultScheduler)
Calls the associated hook function.
static Scheduler onNewThreadScheduler(Scheduler defaultScheduler)
Calls the associated hook function.
static Runnable onSchedule(Runnable run)
Called when a task is scheduled.
static Scheduler onSingleScheduler(Scheduler defaultScheduler)
Calls the associated hook function.
static CompletableObserver onSubscribe(Completable source, CompletableObserver observer)
Calls the associated hook function.
static <T> MaybeObserver<? super T> onSubscribe(Maybe<T> source, MaybeObserver<? super T> subscriber)
Calls the associated hook function.
static <T> Subscriber<? super T> onSubscribe(Flowable<T> source, Subscriber<? super T> subscriber)
Calls the associated hook function.
static <T> Observer<? super T> onSubscribe(Observable<T> source, Observer<? super T> observer)
Calls the associated hook function.
static <T> SingleObserver<? super T> onSubscribe(Single<T> source, SingleObserver<? super T> observer)
Calls the associated hook function.
static void reset()
Removes all handlers and resets to default behavior.
static void setComputationSchedulerHandler(Function<? super Scheduler, ? extends Scheduler> handler)
Sets the specific hook function.
static void setErrorHandler(Consumer<? super Throwable> handler)
Sets the specific hook function.
static void setFailOnNonBlockingScheduler(boolean enable)
Enables or disables the blockingX operators to fail with an IllegalStateException on a non-blocking scheduler such as computation or single.
static void setInitComputationSchedulerHandler(Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
Sets the specific hook function.
static void setInitIoSchedulerHandler(Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
Sets the specific hook function.
static void setInitNewThreadSchedulerHandler(Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
Sets the specific hook function.
static void setInitSingleSchedulerHandler(Function<? super Callable<Scheduler>, ? extends Scheduler> handler)
Sets the specific hook function.
static void setIoSchedulerHandler(Function<? super Scheduler, ? extends Scheduler> handler)
Sets the specific hook function.
static void setNewThreadSchedulerHandler(Function<? super Scheduler, ? extends Scheduler> handler)
Sets the specific hook function.
static void setOnBeforeBlocking(BooleanSupplier handler)
Set the handler that is called when an operator attempts a blocking await; the handler should return true to prevent the blocking and to signal an IllegalStateException instead.
static void setOnCompletableAssembly(Function<? super Completable, ? extends Completable> onCompletableAssembly)
Sets the specific hook function.
static void setOnCompletableSubscribe(BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)
Sets the specific hook function.
static void setOnConnectableFlowableAssembly(Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)
Sets the specific hook function.
static void setOnConnectableObservableAssembly(Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)
Sets the specific hook function.
static void setOnFlowableAssembly(Function<? super Flowable, ? extends Flowable> onFlowableAssembly)
Sets the specific hook function.
static void setOnFlowableSubscribe(BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)
Sets the specific hook function.
static void setOnMaybeAssembly(Function<? super Maybe, ? extends Maybe> onMaybeAssembly)
Sets the specific hook function.
static void setOnMaybeSubscribe(BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)
Sets the specific hook function.
static void setOnObservableAssembly(Function<? super Observable, ? extends Observable> onObservableAssembly)
Sets the specific hook function.
static void setOnObservableSubscribe(BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)
Sets the specific hook function.
static void setOnParallelAssembly(Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)
Sets the specific hook function.
static void setOnSingleAssembly(Function<? super Single, ? extends Single> onSingleAssembly)
Sets the specific hook function.
static void setOnSingleSubscribe(BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)
Sets the specific hook function.
static void setScheduleHandler(Function<? super Runnable, ? extends Runnable> handler)
Sets the specific hook function.
static void setSingleSchedulerHandler(Function<? super Scheduler, ? extends Scheduler> handler)
Sets the specific hook function.
[Expand]
Inherited Methods
From class java.lang.Object

Public Methods

public static Scheduler createComputationScheduler (ThreadFactory threadFactory)

Create an instance of the default Scheduler used for computation() except using threadFactory for thread creation.

History: 2.0.5 - experimental

Parameters
threadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.
Returns
  • the created Scheduler instance

public static Scheduler createIoScheduler (ThreadFactory threadFactory)

Create an instance of the default Scheduler used for io() except using threadFactory for thread creation.

History: 2.0.5 - experimental

Parameters
threadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.
Returns
  • the created Scheduler instance

public static Scheduler createNewThreadScheduler (ThreadFactory threadFactory)

Create an instance of the default Scheduler used for newThread() except using threadFactory for thread creation.

History: 2.0.5 - experimental

Parameters
threadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.
Returns
  • the created Scheduler instance

public static Scheduler createSingleScheduler (ThreadFactory threadFactory)

Create an instance of the default Scheduler used for single() except using threadFactory for thread creation.

History: 2.0.5 - experimental

Parameters
threadFactory thread factory to use for creating worker threads. Note that this takes precedence over any system properties for configuring new thread creation. Cannot be null.
Returns
  • the created Scheduler instance

public static Function<? super Scheduler, ? extends Scheduler> getComputationSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Consumer<? super Throwable> getErrorHandler ()

Returns the a hook consumer.

Returns
  • the hook consumer, may be null

public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitComputationSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitIoSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitNewThreadSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Callable<Scheduler>, ? extends Scheduler> getInitSingleSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Scheduler, ? extends Scheduler> getIoSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Scheduler, ? extends Scheduler> getNewThreadSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BooleanSupplier getOnBeforeBlocking ()

Returns the current blocking handler or null if no custom handler is set.

History: 2.0.5 - experimental

Returns
  • the current blocking handler or null if not specified

public static Function<? super Completable, ? extends Completable> getOnCompletableAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> getOnCompletableSubscribe ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super ConnectableFlowable, ? extends ConnectableFlowable> getOnConnectableFlowableAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super ConnectableObservable, ? extends ConnectableObservable> getOnConnectableObservableAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Flowable, ? extends Flowable> getOnFlowableAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> getOnFlowableSubscribe ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Maybe, ? extends Maybe> getOnMaybeAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BiFunction<? super Maybe, ? super MaybeObserver, ? extends MaybeObserver> getOnMaybeSubscribe ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Observable, ? extends Observable> getOnObservableAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BiFunction<? super Observable, ? super Observer, ? extends Observer> getOnObservableSubscribe ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super ParallelFlowable, ? extends ParallelFlowable> getOnParallelAssembly ()

Returns the current hook function.

History: 2.0.6 - experimental

Returns
  • the hook function, may be null

public static Function<? super Single, ? extends Single> getOnSingleAssembly ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> getOnSingleSubscribe ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Runnable, ? extends Runnable> getScheduleHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Function<? super Scheduler, ? extends Scheduler> getSingleSchedulerHandler ()

Returns the current hook function.

Returns
  • the hook function, may be null

public static Scheduler initComputationScheduler (Callable<Scheduler> defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler a Callable which returns the hook's input value
Returns
  • the value returned by the hook, not null
Throws
NullPointerException if the callable parameter or its result are null

public static Scheduler initIoScheduler (Callable<Scheduler> defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler a Callable which returns the hook's input value
Returns
  • the value returned by the hook, not null
Throws
NullPointerException if the callable parameter or its result are null

public static Scheduler initNewThreadScheduler (Callable<Scheduler> defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler a Callable which returns the hook's input value
Returns
  • the value returned by the hook, not null
Throws
NullPointerException if the callable parameter or its result are null

public static Scheduler initSingleScheduler (Callable<Scheduler> defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler a Callable which returns the hook's input value
Returns
  • the value returned by the hook, not null
Throws
NullPointerException if the callable parameter or its result are null

public static boolean isFailOnNonBlockingScheduler ()

Returns true if the blockingX operators fail with an IllegalStateException on a non-blocking scheduler such as computation or single.

History: 2.0.5 - experimental

Returns
  • true if the blockingX operators fail on a non-blocking scheduler

public static boolean isLockdown ()

Returns true if the plugins were locked down.

Returns
  • true if the plugins were locked down

public static void lockdown ()

Prevents changing the plugins from then on.

This allows container-like environments to prevent clients messing with plugins.

public static Single<T> onAssembly (Single<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static Observable<T> onAssembly (Observable<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static ConnectableFlowable<T> onAssembly (ConnectableFlowable<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static Flowable<T> onAssembly (Flowable<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static ParallelFlowable<T> onAssembly (ParallelFlowable<T> source)

Calls the associated hook function.

History: 2.0.6 - experimental

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static Maybe<T> onAssembly (Maybe<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static Completable onAssembly (Completable source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static ConnectableObservable<T> onAssembly (ConnectableObservable<T> source)

Calls the associated hook function.

Parameters
source the hook's input value
Returns
  • the value returned by the hook

public static boolean onBeforeBlocking ()

Called before an operator attempts a blocking operation such as awaiting a condition or signal and should return true to indicate the operator should not block but throw an IllegalArgumentException.

History: 2.0.5 - experimental

Returns
  • true if the blocking should be prevented
See Also

public static Scheduler onComputationScheduler (Scheduler defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler the hook's input value
Returns
  • the value returned by the hook

public static void onError (Throwable error)

Called when an undeliverable error occurs.

Parameters
error the error to report

public static Scheduler onIoScheduler (Scheduler defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler the hook's input value
Returns
  • the value returned by the hook

public static Scheduler onNewThreadScheduler (Scheduler defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler the hook's input value
Returns
  • the value returned by the hook

public static Runnable onSchedule (Runnable run)

Called when a task is scheduled.

Parameters
run the runnable instance
Returns
  • the replacement runnable

public static Scheduler onSingleScheduler (Scheduler defaultScheduler)

Calls the associated hook function.

Parameters
defaultScheduler the hook's input value
Returns
  • the value returned by the hook

public static CompletableObserver onSubscribe (Completable source, CompletableObserver observer)

Calls the associated hook function.

Parameters
source the hook's input value
observer the observer
Returns
  • the value returned by the hook

public static MaybeObserver<? super T> onSubscribe (Maybe<T> source, MaybeObserver<? super T> subscriber)

Calls the associated hook function.

Parameters
source the hook's input value
subscriber the subscriber
Returns
  • the value returned by the hook

public static Subscriber<? super T> onSubscribe (Flowable<T> source, Subscriber<? super T> subscriber)

Calls the associated hook function.

Parameters
source the hook's input value
subscriber the subscriber
Returns
  • the value returned by the hook

public static Observer<? super T> onSubscribe (Observable<T> source, Observer<? super T> observer)

Calls the associated hook function.

Parameters
source the hook's input value
observer the observer
Returns
  • the value returned by the hook

public static SingleObserver<? super T> onSubscribe (Single<T> source, SingleObserver<? super T> observer)

Calls the associated hook function.

Parameters
source the hook's input value
observer the observer
Returns
  • the value returned by the hook

public static void reset ()

Removes all handlers and resets to default behavior.

public static void setComputationSchedulerHandler (Function<? super Scheduler, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed

public static void setErrorHandler (Consumer<? super Throwable> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed

public static void setFailOnNonBlockingScheduler (boolean enable)

Enables or disables the blockingX operators to fail with an IllegalStateException on a non-blocking scheduler such as computation or single.

History: 2.0.5 - experimental

Parameters
enable enable or disable the feature

public static void setInitComputationSchedulerHandler (Function<? super Callable<Scheduler>, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed, but the function may not return null

public static void setInitIoSchedulerHandler (Function<? super Callable<Scheduler>, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed, but the function may not return null

public static void setInitNewThreadSchedulerHandler (Function<? super Callable<Scheduler>, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed, but the function may not return null

public static void setInitSingleSchedulerHandler (Function<? super Callable<Scheduler>, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed, but the function may not return null

public static void setIoSchedulerHandler (Function<? super Scheduler, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed

public static void setNewThreadSchedulerHandler (Function<? super Scheduler, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed

public static void setOnBeforeBlocking (BooleanSupplier handler)

Set the handler that is called when an operator attempts a blocking await; the handler should return true to prevent the blocking and to signal an IllegalStateException instead.

History: 2.0.5 - experimental

Parameters
handler the handler to set, null resets to the default handler that always returns false
See Also

public static void setOnCompletableAssembly (Function<? super Completable, ? extends Completable> onCompletableAssembly)

Sets the specific hook function.

Parameters
onCompletableAssembly the hook function to set, null allowed

public static void setOnCompletableSubscribe (BiFunction<? super Completable, ? super CompletableObserver, ? extends CompletableObserver> onCompletableSubscribe)

Sets the specific hook function.

Parameters
onCompletableSubscribe the hook function to set, null allowed

public static void setOnConnectableFlowableAssembly (Function<? super ConnectableFlowable, ? extends ConnectableFlowable> onConnectableFlowableAssembly)

Sets the specific hook function.

Parameters
onConnectableFlowableAssembly the hook function to set, null allowed

public static void setOnConnectableObservableAssembly (Function<? super ConnectableObservable, ? extends ConnectableObservable> onConnectableObservableAssembly)

Sets the specific hook function.

Parameters
onConnectableObservableAssembly the hook function to set, null allowed

public static void setOnFlowableAssembly (Function<? super Flowable, ? extends Flowable> onFlowableAssembly)

Sets the specific hook function.

Parameters
onFlowableAssembly the hook function to set, null allowed

public static void setOnFlowableSubscribe (BiFunction<? super Flowable, ? super Subscriber, ? extends Subscriber> onFlowableSubscribe)

Sets the specific hook function.

Parameters
onFlowableSubscribe the hook function to set, null allowed

public static void setOnMaybeAssembly (Function<? super Maybe, ? extends Maybe> onMaybeAssembly)

Sets the specific hook function.

Parameters
onMaybeAssembly the hook function to set, null allowed

public static void setOnMaybeSubscribe (BiFunction<? super Maybe, MaybeObserver, ? extends MaybeObserver> onMaybeSubscribe)

Sets the specific hook function.

Parameters
onMaybeSubscribe the hook function to set, null allowed

public static void setOnObservableAssembly (Function<? super Observable, ? extends Observable> onObservableAssembly)

Sets the specific hook function.

Parameters
onObservableAssembly the hook function to set, null allowed

public static void setOnObservableSubscribe (BiFunction<? super Observable, ? super Observer, ? extends Observer> onObservableSubscribe)

Sets the specific hook function.

Parameters
onObservableSubscribe the hook function to set, null allowed

public static void setOnParallelAssembly (Function<? super ParallelFlowable, ? extends ParallelFlowable> handler)

Sets the specific hook function.

History: 2.0.6 - experimental

Parameters
handler the hook function to set, null allowed

public static void setOnSingleAssembly (Function<? super Single, ? extends Single> onSingleAssembly)

Sets the specific hook function.

Parameters
onSingleAssembly the hook function to set, null allowed

public static void setOnSingleSubscribe (BiFunction<? super Single, ? super SingleObserver, ? extends SingleObserver> onSingleSubscribe)

Sets the specific hook function.

Parameters
onSingleSubscribe the hook function to set, null allowed

public static void setScheduleHandler (Function<? super Runnable, ? extends Runnable> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed

public static void setSingleSchedulerHandler (Function<? super Scheduler, ? extends Scheduler> handler)

Sets the specific hook function.

Parameters
handler the hook function to set, null allowed