This is an automated email from the ASF dual-hosted git repository.
pjfanning pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko-persistence-r2dbc.git
The following commit(s) were added to refs/heads/main by this push:
new cfcfecb Update EventsBySlicePubSubSpec.scala (#458)
cfcfecb is described below
commit cfcfecb85db6cb8b7ad14df7f0308f9b7c8a6e02
Author: PJ Fanning <[email protected]>
AuthorDate: Mon Jul 27 10:56:24 2026 +0100
Update EventsBySlicePubSubSpec.scala (#458)
---
.../pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala | 7 ++++++-
1 file changed, 6 insertions(+), 1 deletion(-)
diff --git
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
index c68daf6..34d8614 100644
---
a/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
+++
b/core/src/test/scala/org/apache/pekko/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
@@ -331,13 +331,18 @@ class EventsBySlicePubSubSpec
}
}
+ // warmup: ensure all streams are fully ready to receive events before
the real assertions
+ val queryIndex =
querySliceRanges.indexOf(querySliceRanges.find(_.contains(slice)).get)
+ persister ! PersistWithAck("warmup", probe.ref)
+ probe.expectMessage(Done)
+ queries(queryIndex).expectNext(5.seconds).event shouldBe "warmup"
+
for (i <- 1 to 10) {
persister ! PersistWithAck(s"e-$i", probe.ref)
probe.expectMessage(Done)
}
for (i <- 1 to 10) {
- val queryIndex =
querySliceRanges.indexOf(querySliceRanges.find(_.contains(slice)).get)
queries(queryIndex).expectNext().event shouldBe s"e-$i"
}
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
