The persistence testkit incorrectly assumed a response was available immediately (#29193)
This commit is contained in:
parent
c287fff034
commit
34b9a26b98
1 changed files with 1 additions and 2 deletions
|
|
@ -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].")
|
||||
|
|
|
|||
Loading…
Add table
Add a link
Reference in a new issue