fix: avoid ask timeout

akka · Nov 10, 2023 · b07e984 · b07e984
1 parent bb3a598
commit b07e984
Showing 1 changed file with 1 addition and 1 deletion.
diff --git a/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala b/core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala
@@ -182,7 +182,7 @@ abstract class CurrentEventsByTagTest(config: String) extends QueryTestSpec(conf
             if (i > largeNumberOfMessage / 2) {
               Future {
                 latch.await()
-                actor ? TaggedAsyncEvent(Event(i.toString), tag)
+                (actor ? TaggedAsyncEvent(Event(i.toString), tag)) (20.seconds)
               }
             } else {
               actor ? TaggedAsyncEvent(Event(i.toString), tag)