-
public class RxJavaSchedulersHookThis plugin class provides 2 ways to customize Scheduler functionality 1. You may redefine entire schedulers, if you so choose. To do so, override the 3 methods that return Scheduler (io(), computation(), newThread()). 2. You may wrap/decorate an Action0, before it is handed off to a Scheduler. The system- supplied Schedulers (Schedulers.ioScheduler, Schedulers.computationScheduler, Scheduler.newThreadScheduler) all use this hook, so it's a convenient way to modify Scheduler functionality without redefining Schedulers wholesale. Also, when redefining Schedulers, you are free to use/not use the onSchedule decoration hook.
See RxJavaPlugins or the RxJava GitHub Wiki for information on configuring plugins: https://github.com/ReactiveX/RxJava/wiki/Plugins.
-
-
Method Summary
Modifier and Type Method Description static SchedulercreateComputationScheduler()static SchedulercreateComputationScheduler(ThreadFactory threadFactory)static SchedulercreateIoScheduler()static SchedulercreateIoScheduler(ThreadFactory threadFactory)SchedulergetComputationScheduler()SchedulergetIOScheduler()SchedulergetNewThreadScheduler()static SchedulercreateNewThreadScheduler()static SchedulercreateNewThreadScheduler(ThreadFactory threadFactory)Action0onSchedule(Action0 action)Invoked before the Action is handed over to the scheduler. static RxJavaSchedulersHookgetDefaultInstance()-
-
Method Detail
-
createComputationScheduler
static Scheduler createComputationScheduler()
-
createComputationScheduler
static Scheduler createComputationScheduler(ThreadFactory threadFactory)
-
createIoScheduler
static Scheduler createIoScheduler()
-
createIoScheduler
static Scheduler createIoScheduler(ThreadFactory threadFactory)
-
getComputationScheduler
Scheduler getComputationScheduler()
-
getIOScheduler
Scheduler getIOScheduler()
-
getNewThreadScheduler
Scheduler getNewThreadScheduler()
-
createNewThreadScheduler
static Scheduler createNewThreadScheduler()
-
createNewThreadScheduler
static Scheduler createNewThreadScheduler(ThreadFactory threadFactory)
-
onSchedule
@Deprecated() Action0 onSchedule(Action0 action)
Invoked before the Action is handed over to the scheduler. Can be used for wrapping/decorating/logging.The default is just a pass through.
- Parameters:
action- action to schedule
-
getDefaultInstance
static RxJavaSchedulersHook getDefaultInstance()
-
-
-
-