From cd2b9bcd119ad7273d268097d2f41f42c2eebc27 Mon Sep 17 00:00:00 2001
From: Debasish Ghosh <dghosh@acm.org>
Date: Thu, 26 Aug 2021 21:59:16 +0530
Subject: [PATCH] Fixes Java test on null empty state: try to avoid race
 condition by waiting for 1 persistent actor to stop before starting the next
 one (#30579)

---
 .../akka/persistence/typed/javadsl/NullEmptyStateTest.java    | 4 ++++
 1 file changed, 4 insertions(+)

diff --git a/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/NullEmptyStateTest.java b/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/NullEmptyStateTest.java
index bc39aef77d..5729e2d419 100644
--- a/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/NullEmptyStateTest.java
+++ b/akka-persistence-typed/src/test/java/akka/persistence/typed/javadsl/NullEmptyStateTest.java
@@ -90,6 +90,8 @@ public class NullEmptyStateTest extends JUnitSuite {
     ActorRef<String> ref1 = testKit.spawn(b);
     probe.expectMessage("onRecoveryCompleted:null");
     ref1.tell("stop");
+    // wait till ref1 stops
+    probe.expectTerminated(ref1);
 
     ActorRef<String> ref2 = testKit.spawn(b);
     probe.expectMessage("onRecoveryCompleted:null");
@@ -99,6 +101,8 @@ public class NullEmptyStateTest extends JUnitSuite {
     probe.expectMessage("eventHandler:one:two");
 
     ref2.tell("stop");
+    // wait till ref2 stops
+    probe.expectTerminated(ref2);
     ActorRef<String> ref3 = testKit.spawn(b);
     // eventHandler from reply
     probe.expectMessage("eventHandler:null:one");