Class OnScheduleMultiHandlerManager
- java.lang.Object
-
- hu.akarnokd.rxjava3.debug.multihook.MultiHandlerManager<Function<java.lang.Runnable,java.lang.Runnable>>
-
- hu.akarnokd.rxjava3.debug.multihook.OnScheduleMultiHandlerManager
-
- All Implemented Interfaces:
BiConsumer<java.lang.Runnable[],Function<java.lang.Runnable,java.lang.Runnable>>,Function<java.lang.Runnable,java.lang.Runnable>
public class OnScheduleMultiHandlerManager extends MultiHandlerManager<Function<java.lang.Runnable,java.lang.Runnable>> implements Function<java.lang.Runnable,java.lang.Runnable>, BiConsumer<java.lang.Runnable[],Function<java.lang.Runnable,java.lang.Runnable>>
Handles the OnSchedule hooks.Use
enable()to install the single global RxJavaPlugins handler.- Since:
- 0.18.0
-
-
Field Summary
-
Fields inherited from class hu.akarnokd.rxjava3.debug.multihook.MultiHandlerManager
handlers
-
-
Constructor Summary
Constructors Constructor Description OnScheduleMultiHandlerManager()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description voidaccept(java.lang.Runnable[] t1, Function<java.lang.Runnable,java.lang.Runnable> t2)voidappend()Adds the current non-null OnSchedule hook to this handler and replaces it in RxJavaPlugins with this OnScheduleMultiHandlerManager.java.lang.Runnableapply(java.lang.Runnable t)voiddisable()Disables this manager by restoring anullOnSchedule hook.voidenable()Enables this manager by replacing any existing OnSchedule hook in RxJavaPlugins.-
Methods inherited from class hu.akarnokd.rxjava3.debug.multihook.MultiHandlerManager
clear, forEach, forEach, hasHandlers, register
-
-
-
-
Method Detail
-
enable
public void enable()
Enables this manager by replacing any existing OnSchedule hook in RxJavaPlugins.
-
disable
public void disable()
Disables this manager by restoring anullOnSchedule hook.
-
append
public void append()
Adds the current non-null OnSchedule hook to this handler and replaces it in RxJavaPlugins with this OnScheduleMultiHandlerManager.
-
apply
public java.lang.Runnable apply(java.lang.Runnable t) throws java.lang.Exception
-
accept
public void accept(java.lang.Runnable[] t1, Function<java.lang.Runnable,java.lang.Runnable> t2) throws java.lang.Throwable- Specified by:
acceptin interfaceBiConsumer<java.lang.Runnable[],Function<java.lang.Runnable,java.lang.Runnable>>- Throws:
java.lang.Throwable
-
-