public class CoreScheduler extends rx.Scheduler implements ShutdownHook
Constructor and Description |
---|
CoreScheduler(int poolSize)
Create a scheduler with specified pool size and using
least-recent worker selection policy.
|
Modifier and Type | Method and Description |
---|---|
rx.Scheduler.Worker |
createWorker() |
boolean |
isShutdown() |
rx.Subscription |
scheduleDirect(rx.functions.Action0 action)
Schedules the action directly on one of the event loop workers
without the additional infrastructure and checking.
|
rx.Observable<Boolean> |
shutdown() |
void |
start() |
public CoreScheduler(int poolSize)
public void start()
public rx.Observable<Boolean> shutdown()
shutdown
in interface ShutdownHook
public boolean isShutdown()
isShutdown
in interface ShutdownHook
public rx.Scheduler.Worker createWorker()
createWorker
in class rx.Scheduler
public rx.Subscription scheduleDirect(rx.functions.Action0 action)
action
- the action to scheduleCopyright © 2021 Couchbase, Inc.. All rights reserved.