test: Harden test of RecoveryStrategy.skip

akka · Dec 6, 2023 · db97ac8 · db97ac8
1 parent 9cddb36
commit db97ac8
Show file tree

Hide file tree

Showing 4 changed files with 13 additions and 5 deletions.
diff --git a/akka-projection-jdbc/src/it/scala/akka/projection/jdbc/JdbcProjectionSpec.scala b/akka-projection-jdbc/src/it/scala/akka/projection/jdbc/JdbcProjectionSpec.scala
@@ -361,7 +361,9 @@ class JdbcProjectionSpec
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
       }
-      offsetShouldBe(6L)
+      eventually {
+        offsetShouldBe(6L)
+      }
     }
 
     "skip failing events after retrying when using RecoveryStrategy.retryAndSkip" in {

diff --git a/akka-projection-r2dbc/src/it/scala/akka/projection/r2dbc/R2dbcProjectionSpec.scala b/akka-projection-r2dbc/src/it/scala/akka/projection/r2dbc/R2dbcProjectionSpec.scala
@@ -329,7 +329,9 @@ class R2dbcProjectionSpec
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
       }
-      offsetShouldBe(6L)
+      eventually {
+        offsetShouldBe(6L)
+      }
     }
 
     "skip failing events after retrying when using RecoveryStrategy.retryAndSkip" in {

diff --git a/...jection-r2dbc/src/it/scala/akka/projection/r2dbc/R2dbcTimestampOffsetProjectionSpec.scala b/...jection-r2dbc/src/it/scala/akka/projection/r2dbc/R2dbcTimestampOffsetProjectionSpec.scala
@@ -418,7 +418,9 @@ class R2dbcTimestampOffsetProjectionSpec
       projectionTestKit.run(projectionFailing) {
         projectedValueShouldBe("e1|e2|e3|e4|e5")
       }
-      offsetShouldBe(envelopes.last.offset)
+      eventually {
+        offsetShouldBe(envelopes.last.offset)
+      }
     }
 
     "skip failing events after retrying when using RecoveryStrategy.retryAndSkip" in {

diff --git a/akka-projection-slick/src/test/scala/akka/projection/slick/SlickProjectionSpec.scala b/akka-projection-slick/src/test/scala/akka/projection/slick/SlickProjectionSpec.scala
@@ -273,8 +273,10 @@ class SlickProjectionSpec
         }
       }
       withClue("check - all offsets were seen") {
-        val offset = offsetStore.readOffset[Long](projectionId).futureValue.value
-        offset shouldBe 6L
+        eventually {
+          val offset = offsetStore.readOffset[Long](projectionId).futureValue.value
+          offset shouldBe 6L
+        }
       }
     }