reactor.adapter.akka

Class ActorScheduler

java.lang.Object

reactor.adapter.akka.ActorScheduler

All Implemented Interfaces:

reactor.core.Disposable, reactor.core.scheduler.Scheduler

public class ActorScheduler
extends Object
implements reactor.core.scheduler.Scheduler

A Scheduler implementation that given an ActorSystem, creates a single Actor and routes all Scheduler/Worker calls to it.

Nested Class Summary

Nested classes/interfaces inherited from interface reactor.core.scheduler.Scheduler

reactor.core.scheduler.Scheduler.Worker

Nested classes/interfaces inherited from interface reactor.core.Disposable

reactor.core.Disposable.Composite, reactor.core.Disposable.Swap

Method Summary

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)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Methods inherited from interface reactor.core.scheduler.Scheduler

dispose, disposeGracefully, init, now, schedule, schedulePeriodically, start

Methods inherited from interface reactor.core.Disposable

isDisposed

Method Detail

from

public static reactor.core.scheduler.Scheduler from(akka.actor.ActorSystem system)

Parameters:

system - an ActorSystem

Returns:

a new Scheduler

from

public static reactor.core.scheduler.Scheduler from(akka.actor.ActorRef actorRef)

Parameters:

actorRef - an ActorRef

Returns:

a new Scheduler

schedule

public reactor.core.Disposable schedule(Runnable task)

Specified by:

schedule in interface reactor.core.scheduler.Scheduler

createWorker

public reactor.core.scheduler.Scheduler.Worker createWorker()

Specified by:

createWorker in interface reactor.core.scheduler.Scheduler