We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 5ceb36e commit 7199f96Copy full SHA for 7199f96
core/src/test/scala/akka/persistence/jdbc/query/CurrentEventsByTagTest.scala
@@ -193,7 +193,7 @@ abstract class CurrentEventsByTagTest(config: String) extends QueryTestSpec(conf
193
journalOps.withCurrentEventsByTag()(tag, NoOffset) { tp =>
194
// The stream must complete within the given amount of time
195
// This make take a while in case the journal sequence actor detects gaps
196
- val allEvents = tp.toStrict(atMost = 20.seconds)
+ val allEvents = tp.toStrict(atMost = 40.seconds)
197
allEvents.size should be >= 600
198
val expectedOffsets = 1L.to(allEvents.size).map(Sequence.apply)
199
allEvents.map(_.offset) shouldBe expectedOffsets
0 commit comments