reactor.adapter.akka

Class ActorScheduler

java.lang.Object

reactor.adapter.akka.ActorScheduler

All Implemented Interfaces:

Disposable, Scheduler

public class ActorScheduler
extends Object
implements 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

Scheduler.Worker

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

Disposable.Composite, Disposable.Swap

Method Summary

Modifier and Type	Method and Description
Scheduler.Worker	createWorker()
static Scheduler	from(akka.actor.ActorRef actorRef)
static Scheduler	from(akka.actor.ActorSystem system)
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 Scheduler from(akka.actor.ActorSystem system)

Parameters:

system - an ActorSystem

Returns:

a new Scheduler

from

public static Scheduler from(akka.actor.ActorRef actorRef)

Parameters:

actorRef - an ActorRef

Returns:

a new Scheduler

schedule

public Disposable schedule(Runnable task)

Specified by:

schedule in interface Scheduler

createWorker

public Scheduler.Worker createWorker()

Specified by:

createWorker in interface Scheduler