public class ActorScheduler extends Object implements reactor.core.scheduler.Scheduler
Modifier and Type | Method and Description |
---|---|
reactor.core.scheduler.Scheduler.Worker |
createWorker() |
static reactor.core.scheduler.Scheduler |
from(akka.actor.ActorRef actorRef) |
static reactor.core.scheduler.Scheduler |
from(akka.actor.ActorSystem system) |
reactor.core.Disposable |
schedule(Runnable task) |
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
public static reactor.core.scheduler.Scheduler from(akka.actor.ActorSystem system)
system
- an ActorSystem
Scheduler
public static reactor.core.scheduler.Scheduler from(akka.actor.ActorRef actorRef)
actorRef
- an ActorRef
Scheduler
public reactor.core.Disposable schedule(Runnable task)
schedule
in interface reactor.core.scheduler.Scheduler
public reactor.core.scheduler.Scheduler.Worker createWorker()
createWorker
in interface reactor.core.scheduler.Scheduler