From 4d9a081e5069803eeb125654ea51aebc3b757761 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Wed, 1 Apr 2026 00:57:10 +0200 Subject: [PATCH 1/2] no need to run every parallelism value --- .../scaladsl/FlowFlatMapConcatParallelismSpec.scala | 9 ++++++--- 1 file changed, 6 insertions(+), 3 deletions(-) diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala index a36f9beab4..30eecd5fb6 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala @@ -47,9 +47,12 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec(""" val toSeq = Flow[Int].grouped(1000).toMat(Sink.head)(Keep.right) class BoomException extends RuntimeException("BOOM~~") with NoStackTrace + + val checkValues = List(1, 2, 4, 8, 16, 32, 64, 128) + "A flatMapConcat" must { - for (i <- 1 until 129) { + for (i <- checkValues) { s"work with value presented sources with parallelism: $i" in { Source( List( @@ -98,7 +101,7 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec(""" (sum, seq) } - for (i <- 1 until 129) { + for (i <- checkValues) { s"work with generated value presented sources with parallelism: $i " in { val (sum, sources @ _) = generateRandomValuePresentedSources(100000) Source(sources) @@ -109,7 +112,7 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec(""" } } - for (i <- 1 until 129) { + for (i <- checkValues) { s"work with generated value sequenced sources with parallelism: $i " in { val (sum, sources @ _) = generateSequencedValuePresentedSources(100000) Source(sources) From 0897ac41bbcfbd98d5faca21072c7c8421e9e264 Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Wed, 1 Apr 2026 09:57:47 +0200 Subject: [PATCH 2/2] Update FlowFlatMapConcatParallelismSpec.scala --- .../stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala index 30eecd5fb6..df7a7ddb14 100644 --- a/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala +++ b/stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala @@ -49,7 +49,7 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec(""" class BoomException extends RuntimeException("BOOM~~") with NoStackTrace val checkValues = List(1, 2, 4, 8, 16, 32, 64, 128) - + "A flatMapConcat" must { for (i <- checkValues) {