fix: use barrier to block the persisting

akka · Nov 1, 2023 · 733aa96 · 733aa96
1 parent 603bded
commit 733aa96
Showing 1 changed file with 6 additions and 2 deletions.
diff --git a/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala b/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala
@@ -178,9 +178,13 @@ abstract class CurrentEventsByTagTest(config: String) extends QueryTestSpec(conf
           val futures = for (actor <- Seq(actor1, actor2, actor3); i <- 1 to numberOfMessagesPerActor) yield {
             // block the execution
             if (i == numberOfMessagesPerActor / 2) {
-              latch.await()
+              Future {
+                latch.await()
+                actor ? TaggedAsyncEvent(Event(i.toString), tag)
+              }
+            } else {
+              actor ? TaggedAsyncEvent(Event(i.toString), tag)
             }
-            actor ? TaggedAsyncEvent(Event(i.toString), tag)
           }
           Future.sequence(futures).map(_ => Done)
         }