hu.akarnokd.rxjava3.debug.multihook

Class OnScheduleMultiHandlerManager

java.lang.Object

hu.akarnokd.rxjava3.debug.multihook.MultiHandlerManager<Function<Runnable,Runnable>>

hu.akarnokd.rxjava3.debug.multihook.OnScheduleMultiHandlerManager

All Implemented Interfaces:

BiConsumer<Runnable[],Function<Runnable,Runnable>>, Function<Runnable,Runnable>

public class OnScheduleMultiHandlerManager
extends MultiHandlerManager<Function<Runnable,Runnable>>
implements Function<Runnable,Runnable>, BiConsumer<Runnable[],Function<Runnable,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 and Description
OnScheduleMultiHandlerManager()

Method Summary

Modifier and Type	Method and Description
void	accept(Runnable[] t1, Function<Runnable,Runnable> t2)
void	append() Adds the current non-null OnSchedule hook to this handler and replaces it in RxJavaPlugins with this OnScheduleMultiHandlerManager.
Runnable	apply(Runnable t)
void	disable() Disables this manager by restoring a null OnSchedule hook.
void	enable() 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

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Detail

OnScheduleMultiHandlerManager

public OnScheduleMultiHandlerManager()

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 a null OnSchedule 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 Runnable apply(Runnable t)
               throws Exception

Specified by:

apply in interface Function<Runnable,Runnable>

Throws:

Exception

accept

public void accept(Runnable[] t1,
                   Function<Runnable,Runnable> t2)
            throws Throwable

Specified by:

accept in interface BiConsumer<Runnable[],Function<Runnable,Runnable>>

Throws:

Throwable