From 65442bd6a930458bd1ff03c87f93b3e0c6be06c8 Mon Sep 17 00:00:00 2001 From: Debasish Ghosh Date: Fri, 27 Aug 2021 13:23:42 +0530 Subject: [PATCH] Fixed yet another race condition --- .../typed/scaladsl/EventSourcedBehaviorSpec.scala | 5 +++++ 1 file changed, 5 insertions(+) diff --git a/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala b/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala index 70daec0a84..8dfb9ed109 100644 --- a/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala +++ b/akka-persistence-typed-tests/src/test/scala/akka/persistence/typed/scaladsl/EventSourcedBehaviorSpec.scala @@ -360,9 +360,14 @@ class EventSourcedBehaviorSpec val counterDefaultRecoveryStrategy = spawn(counterWithRecoveryStrategy(Recovery.default)) counterSetup ! Increment + counterSetup ! StopIt probe.expectTerminated(counterSetup) + counterDefaultRecoveryStrategy ! GetValue(probe.ref) + counterDefaultRecoveryStrategy ! StopIt + probe.expectTerminated(counterDefaultRecoveryStrategy) + probe.expectMessage(State(4, Vector(0, 1, 2, 3))) val counterDisabledRecoveryStrategy = spawn(counterWithRecoveryStrategy(Recovery.disabled))