Package | Description |
---|---|
io.reactivex |
Base reactive classes:
Flowable , Observable ,
Single , Maybe and
Completable ; base reactive consumers;
other common base interfaces. |
io.reactivex.internal.schedulers | |
io.reactivex.schedulers |
Scheduler implementations, value+time record class and the standard factory class to
return standard RxJava schedulers or wrap any Executor-based (thread pool) instances.
|
Modifier and Type | Method and Description |
---|---|
abstract Scheduler.Worker |
Scheduler.createWorker()
Retrieves or creates a new
Scheduler.Worker that represents sequential execution of actions. |
Modifier and Type | Class and Description |
---|---|
static class |
ExecutorScheduler.ExecutorWorker |
class |
NewThreadWorker
Base class that manages a single-threaded ScheduledExecutorService as a
worker but doesn't perform task-tracking operations.
|
Modifier and Type | Method and Description |
---|---|
Scheduler.Worker |
ImmediateThinScheduler.createWorker() |
Scheduler.Worker |
ExecutorScheduler.createWorker() |
Scheduler.Worker |
SingleScheduler.createWorker() |
Scheduler.Worker |
ComputationScheduler.createWorker() |
Scheduler.Worker |
TrampolineScheduler.createWorker() |
Scheduler.Worker |
SchedulerWhen.createWorker() |
Scheduler.Worker |
IoScheduler.createWorker() |
Scheduler.Worker |
NewThreadScheduler.createWorker() |
Modifier and Type | Method and Description |
---|---|
void |
SchedulerMultiWorkerSupport.WorkerCallback.onWorker(int index,
Scheduler.Worker worker)
Called with the Worker index and instance.
|
Modifier and Type | Method and Description |
---|---|
Scheduler.Worker |
TestScheduler.createWorker() |
Copyright © 2018 JBoss by Red Hat. All rights reserved.