akka.io
Class TickGenerator<Cmd,Evt>

java.lang.Object
  extended by akka.io.PipelineStage<HasActorContext,Cmd,Cmd,Evt,Evt>
      extended by akka.io.TickGenerator<Cmd,Evt>

public class TickGenerator<Cmd,Evt>
extends PipelineStage<HasActorContext,Cmd,Cmd,Evt,Evt>

This pipeline stage does not alter the events or commands


Nested Class Summary
static class TickGenerator.Tick
          This message type is emitted by the TickGenerator to the whole pipeline, informing all stages about the time at which this Tick was emitted (relative to some arbitrary epoch).
static class TickGenerator.Tick$
           
static interface TickGenerator.Trigger
          This message type is used by the TickGenerator to trigger the rescheduling of the next Tick.
 
Constructor Summary
TickGenerator(scala.concurrent.duration.FiniteDuration interval)
           
 
Method Summary
 java.lang.Object apply(HasActorContext ctx)
           
 
Methods inherited from class akka.io.PipelineStage
combine, sequence
 
Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
 

Constructor Detail

TickGenerator

public TickGenerator(scala.concurrent.duration.FiniteDuration interval)
Method Detail

apply

public java.lang.Object apply(HasActorContext ctx)