Package akka.actor.testkit.typed.javadsl
Class ManualTime
- java.lang.Object
-
- akka.actor.testkit.typed.javadsl.ManualTime
-
public final class ManualTime extends java.lang.ObjectNot for user instantiation, seeget(akka.actor.typed.ActorSystem<A>)
-
-
Constructor Summary
Constructors Constructor Description ManualTime(ExplicitlyTriggeredScheduler delegate)
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static com.typesafe.config.Configconfig()Config that needs to be in place for the actor system to use the manualvoidexpectNoMessageFor(java.time.Duration duration, TestProbe<?>... on)Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.voidexpectNoMessageFor(java.time.Duration duration, scala.collection.immutable.Seq<TestProbe<?>> on)static <A> ManualTimeget(ActorSystem<A> system)Access the manual scheduler, note that you need to setup the actor system/testkit withManualTime.configfor this to work.voidtimePasses(java.time.Duration amount)Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.
-
-
-
Constructor Detail
-
ManualTime
public ManualTime(ExplicitlyTriggeredScheduler delegate)
-
-
Method Detail
-
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 withManualTime.configfor this to work.
-
expectNoMessageFor
public void expectNoMessageFor(java.time.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(java.time.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(java.time.Duration duration, scala.collection.immutable.Seq<TestProbe<?>> on)
-
-