test: FilteredPayload with more db partitions, #546 (#604)

patriknw · web-flow · commit d4f91c407219 · 2024-10-02T11:22:14.000+02:00
diff --git a/core/src/test/scala/akka/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala b/core/src/test/scala/akka/persistence/r2dbc/query/EventsBySlicePubSubSpec.scala
@@ -200,6 +200,8 @@ class EventsBySlicePubSubSpec
     }
 
     "turn FilteredPayload to filtered events with no payload" in new Setup {
+      pendingIfMoreThanOneDataPartition()
+
       val result: TestSubscriber.Probe[EventEnvelope[String]] =
         query.eventsBySlices[String](this.entityType, 0, 1023, NoOffset).runWith(sinkProbe).request(10)
 

Original file line number	Diff line number	Diff line change
`@@ -200,6 +200,8 @@ class EventsBySlicePubSubSpec`
`200`	`200`	`}`
`201`	`201`
`202`	`202`	`"turn FilteredPayload to filtered events with no payload" in new Setup {`
	`203`	`+ pendingIfMoreThanOneDataPartition()`
	`204`	`+`
`203`	`205`	`val result: TestSubscriber.Probe[EventEnvelope[String]] =`
`204`	`206`	`query.eventsBySlices[String](this.entityType, 0, 1023, NoOffset).runWith(sinkProbe).request(10)`
`205`	`207`