-
public class RxJavaSchedulersHook
This 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 Scheduler
createComputationScheduler()
static Scheduler
createComputationScheduler(ThreadFactory threadFactory)
static Scheduler
createIoScheduler()
static Scheduler
createIoScheduler(ThreadFactory threadFactory)
Scheduler
getComputationScheduler()
Scheduler
getIOScheduler()
Scheduler
getNewThreadScheduler()
static Scheduler
createNewThreadScheduler()
static Scheduler
createNewThreadScheduler(ThreadFactory threadFactory)
Action0
onSchedule(Action0 action)
Invoked before the Action is handed over to the scheduler. static RxJavaSchedulersHook
getDefaultInstance()
-
-
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()
-
-
-
-