Package org.apache.pekko.actor.testkit.typed.javadsl

Class ManualTime

java.lang.Object
org.apache.pekko.actor.testkit.typed.javadsl.ManualTime
public final class ManualTime extends Object
Not for user instantiation, see get(org.apache.pekko.actor.typed.ActorSystem<A>)

  • Constructor Details

  • Method Details

    • config

      public static com.typesafe.config.Config config()
      Config that needs to be in place for the actor system to use the manual

    • get

      public static <A> ManualTime get(ActorSystem<A> 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(Duration 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(Duration 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(Duration duration, scala.collection.immutable.Seq<TestProbe<?>> on)