Class TickGenerator<Cmd,Evt>

  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


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


public java.lang.Object apply(HasActorContext ctx)