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

Class ManualTime

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    ManualTime(ExplicitlyTriggeredScheduler delegate)
     

  • Method Summary

    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 and assert that the probes receive no messages.
    void
    expectNoMessageFor(scala.concurrent.duration.FiniteDuration duration, scala.collection.immutable.Seq<TestProbe<?>> on)
    Advance the clock by the specified duration and assert that the probes receive no messages.
    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

  • Constructor Details

  • Method Details

    • 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 and assert that the probes receive no messages.

      After advancing the clock, each probe waits for the configured pekko.actor.testkit.typed.expect-no-message-default duration so that asynchronously dispatched messages can arrive.

    • 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)
      Advance the clock by the specified duration and assert that the probes receive no messages.

      After advancing the clock, each probe waits for the configured pekko.actor.testkit.typed.expect-no-message-default duration so that asynchronously dispatched messages can arrive.