public final class RxJava3Scheduler extends Object implements reactor.core.scheduler.Scheduler
Scheduler
.Modifier and Type | Method and Description |
---|---|
reactor.core.scheduler.Scheduler.Worker |
createWorker() |
void |
dispose() |
static reactor.core.scheduler.Scheduler |
from(io.reactivex.rxjava3.core.Scheduler scheduler)
Adapt an RxJava 3
Scheduler into a Reactor Scheduler . |
boolean |
isDisposed() |
reactor.core.Disposable |
schedule(Runnable task) |
reactor.core.Disposable |
schedule(Runnable task,
long delay,
TimeUnit unit) |
reactor.core.Disposable |
schedulePeriodically(Runnable task,
long initialDelay,
long period,
TimeUnit unit) |
void |
start() |
public static reactor.core.scheduler.Scheduler from(io.reactivex.rxjava3.core.Scheduler scheduler)
Scheduler
into a Reactor Scheduler
.scheduler
- an RxJava3 Scheduler
Scheduler
public reactor.core.scheduler.Scheduler.Worker createWorker()
createWorker
in interface reactor.core.scheduler.Scheduler
public void dispose()
dispose
in interface reactor.core.Disposable
dispose
in interface reactor.core.scheduler.Scheduler
public boolean isDisposed()
isDisposed
in interface reactor.core.Disposable
public void start()
start
in interface reactor.core.scheduler.Scheduler
public reactor.core.Disposable schedule(Runnable task)
schedule
in interface reactor.core.scheduler.Scheduler
public reactor.core.Disposable schedule(Runnable task, long delay, TimeUnit unit)
schedule
in interface reactor.core.scheduler.Scheduler