Package akka.actor.testkit.typed.javadsl
Class ManualTime
- java.lang.Object
-
- akka.actor.testkit.typed.javadsl.ManualTime
-
public final class ManualTime extends java.lang.Object
Not 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.Config
config()
Config that needs to be in place for the actor system to use the manualvoid
expectNoMessageFor(java.time.Duration duration, TestProbe<?>... on)
Advance the clock by the specified duration, executing all outstanding jobs on the calling thread before returning.void
expectNoMessageFor(java.time.Duration duration, scala.collection.immutable.Seq<TestProbe<?>> on)
static <A> ManualTime
get(ActorSystem<A> system)
Access the manual scheduler, note that you need to setup the actor system/testkit withManualTime.config
for this to work.void
timePasses(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.config
for 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)
-
-