test: extend R2DBC EventSourcedEndToEndSpec (#1292)

akka · Jan 13, 2025 · 4a2eabb · 4a2eabb
1 parent b366cc6
commit 4a2eabb
Show file tree

Hide file tree

Showing 4 changed files with 319 additions and 79 deletions.
diff --git a/...namodb-integration/src/test/scala/akka/projection/dynamodb/EventSourcedEndToEndSpec.scala b/...namodb-integration/src/test/scala/akka/projection/dynamodb/EventSourcedEndToEndSpec.scala
@@ -4,7 +4,6 @@
 
 package akka.projection.dynamodb
 
-import java.lang
 import java.util.UUID
 import java.util.concurrent.CompletionException
 import java.util.concurrent.ConcurrentHashMap
@@ -323,7 +322,7 @@ class EventSourcedEndToEndSpec
 
   private var processedEventsPerProjection: Map[ProjectionId, ConcurrentHashMap[String, java.lang.Boolean]] = Map.empty
 
-  private def processedEvents(projectionId: ProjectionId): ConcurrentHashMap[String, lang.Boolean] = {
+  private def processedEvents(projectionId: ProjectionId): ConcurrentHashMap[String, java.lang.Boolean] = {
     processedEventsPerProjection.get(projectionId) match {
       case None =>
         val processedEvents = new ConcurrentHashMap[String, java.lang.Boolean]
@@ -492,7 +491,7 @@ class EventSourcedEndToEndSpec
         Thread.sleep(1500)
     }
 
-    val projections = startProjectionsFactory()
+    var projections = startProjectionsFactory()
 
     // give them some time to start before writing more events
     Thread.sleep(200)
@@ -518,7 +517,7 @@ class EventSourcedEndToEndSpec
 
       // resume projections again
       if (n == (numberOfEvents / 2) + 20)
-        startProjectionsFactory()
+        projections = startProjectionsFactory()
 
       if (n % 10 == 0)
         Thread.sleep(50)