From 34b9a26b98331b1da0c1302b62f0631700128163 Mon Sep 17 00:00:00 2001 From: =?UTF-8?q?Johan=20Andr=C3=A9n?= Date: Mon, 8 Jun 2020 13:29:51 +0200 Subject: [PATCH] The persistence testkit incorrectly assumed a response was available immediately (#29193) --- .../testkit/internal/EventSourcedBehaviorTestKitImpl.scala | 3 +-- 1 file changed, 1 insertion(+), 2 deletions(-) diff --git a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala index e520b22a4d..12902ee9d8 100644 --- a/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala +++ b/akka-persistence-testkit/src/main/scala/akka/persistence/testkit/internal/EventSourcedBehaviorTestKitImpl.scala @@ -5,7 +5,6 @@ package akka.persistence.testkit.internal import scala.collection.immutable -import scala.concurrent.duration._ import scala.reflect.ClassTag import scala.util.control.NonFatal @@ -143,7 +142,7 @@ import akka.persistence.typed.internal.EventSourcedBehaviorImpl val result = runCommand(command) val reply = try { - replyProbe.receiveMessage(Duration.Zero) + replyProbe.receiveMessage() } catch { case NonFatal(_) => throw new AssertionError(s"Missing expected reply for command [$command].")