Package akka.actor.testkit.typed.scaladsl

Class ManualTime

    • Method Summary

      All Methods Static Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      static ManualTime apply​(ActorSystem<?> system)
      Access the manual scheduler, note that you need to setup the actor system/testkit with ManualTime.config for this to work.
      static com.typesafe.config.Config config()
      Config needed to use the ExplicitlyTriggeredScheduler
      void expectNoMessageFor​(scala.concurrent.duration.FiniteDuration duration, TestProbe<?>... on)
      Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.
      void expectNoMessageFor​(scala.concurrent.duration.FiniteDuration duration, scala.collection.immutable.Seq<TestProbe<?>> on)  
      void timePasses​(scala.concurrent.duration.FiniteDuration amount)
      Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.

      • Methods inherited from class java.lang.Object

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

    • Method Detail

      • config

        public static com.typesafe.config.Config config()
        Config needed to use the ExplicitlyTriggeredScheduler

      • apply

        public static ManualTime apply​(ActorSystem<?> system)
        Access the manual scheduler, note that you need to setup the actor system/testkit with ManualTime.config for this to work.

      • expectNoMessageFor

        public void expectNoMessageFor​(scala.concurrent.duration.FiniteDuration duration,
                               TestProbe<?>... on)
        Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.

        We will not add a dilation factor to this amount, since the scheduler API also does not apply dilation. If you want the amount of time passed to be dilated, apply the dilation before passing the delay to this method.

      • timePasses

        public void timePasses​(scala.concurrent.duration.FiniteDuration amount)
        Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.

        We will not add a dilation factor to this amount, since the scheduler API also does not apply dilation. If you want the amount of time passed to be dilated, apply the dilation before passing the delay to this method.

      • expectNoMessageFor

        public void expectNoMessageFor​(scala.concurrent.duration.FiniteDuration duration,
                               scala.collection.immutable.Seq<TestProbe<?>> on)