diff --git a/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/javadsl/ManualTime.scala b/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/javadsl/ManualTime.scala index 71733ebcce1..ed680012316 100644 --- a/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/javadsl/ManualTime.scala +++ b/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/javadsl/ManualTime.scala @@ -64,7 +64,7 @@ final class ManualTime(delegate: akka.testkit.ExplicitlyTriggeredScheduler) { @varargs def expectNoMessageFor(duration: Duration, on: TestProbe[_]*): Unit = { delegate.timePasses(duration.asScala) - on.foreach(_.expectNoMessage(Duration.ZERO)) + on.foreach(_.expectNoMessage()) } } diff --git a/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/scaladsl/ManualTime.scala b/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/scaladsl/ManualTime.scala index 418d8537be5..f7c8340dcd3 100644 --- a/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/scaladsl/ManualTime.scala +++ b/akka-actor-testkit-typed/src/main/scala/akka/actor/testkit/typed/scaladsl/ManualTime.scala @@ -9,7 +9,7 @@ import akka.actor.typed.internal.adapter.SchedulerAdapter import com.typesafe.config.{ Config, ConfigFactory } import scala.annotation.varargs -import scala.concurrent.duration.{ Duration, FiniteDuration } +import scala.concurrent.duration.FiniteDuration /** * Manual time allows you to do async tests while controlling the scheduler of the system. @@ -63,7 +63,7 @@ final class ManualTime(delegate: akka.testkit.ExplicitlyTriggeredScheduler) { @varargs def expectNoMessageFor(duration: FiniteDuration, on: TestProbe[_]*): Unit = { delegate.timePasses(duration) - on.foreach(_.expectNoMessage(Duration.Zero)) + on.foreach(_.expectNoMessage()) } } diff --git a/akka-actor-testkit-typed/src/test/scala/docs/akka/actor/testkit/typed/scaladsl/ManualTimerExampleSpec.scala b/akka-actor-testkit-typed/src/test/scala/docs/akka/actor/testkit/typed/scaladsl/ManualTimerExampleSpec.scala index 2104c291569..2fb666e2645 100644 --- a/akka-actor-testkit-typed/src/test/scala/docs/akka/actor/testkit/typed/scaladsl/ManualTimerExampleSpec.scala +++ b/akka-actor-testkit-typed/src/test/scala/docs/akka/actor/testkit/typed/scaladsl/ManualTimerExampleSpec.scala @@ -68,6 +68,26 @@ class ManualTimerExampleSpec } } + "detect a message received during specified period" in { + case object Tick + case object Tock + + val probe = TestProbe[Tock.type]() + val behavior = Behaviors.withTimers[Tick.type] { timer => + timer.startSingleTimer(Tick, 10.millis) + Behaviors.receiveMessage { _ => + probe.ref ! Tock + Behaviors.same + } + } + + spawn(behavior) + + assertThrows[AssertionError] { + manualTime.expectNoMessageFor(10.millis, probe) + } + } + "replace timer" in { sealed trait Command case class Tick(n: Int) extends Command