public final class RxJava3Scheduler extends Object implements Scheduler
Scheduler.Scheduler.WorkerDisposable.Composite, Disposable.Swap| Modifier and Type | Method and Description |
|---|---|
Scheduler.Worker |
createWorker() |
void |
dispose() |
static Scheduler |
from(io.reactivex.rxjava3.core.Scheduler scheduler)
Adapt an RxJava 3
Scheduler into a Reactor Scheduler. |
boolean |
isDisposed() |
Disposable |
schedule(Runnable task) |
Disposable |
schedule(Runnable task,
long delay,
TimeUnit unit) |
Disposable |
schedulePeriodically(Runnable task,
long initialDelay,
long period,
TimeUnit unit) |
void |
start() |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, waitdisposeGracefully, init, nowpublic static Scheduler from(io.reactivex.rxjava3.core.Scheduler scheduler)
Scheduler into a Reactor Scheduler.scheduler - an RxJava3 SchedulerSchedulerpublic Scheduler.Worker createWorker()
createWorker in interface Schedulerpublic void dispose()
dispose in interface Disposabledispose in interface Schedulerpublic boolean isDisposed()
isDisposed in interface Disposablepublic Disposable schedule(Runnable task)
public Disposable schedule(Runnable task, long delay, TimeUnit unit)
public Disposable schedulePeriodically(Runnable task, long initialDelay, long period, TimeUnit unit)
schedulePeriodically in interface Scheduler