This is an automated email from the ASF dual-hosted git repository.
hepin pushed a commit to branch main
in repository https://gitbox.apache.org/repos/asf/pekko.git
The following commit(s) were added to refs/heads/main by this push:
new 741e8fc120 no need to run every parallelism value (#2829)
741e8fc120 is described below
commit 741e8fc120818637158bc1ff469ac89ddd8f2632
Author: PJ Fanning <[email protected]>
AuthorDate: Thu Apr 2 06:37:36 2026 +0200
no need to run every parallelism value (#2829)
* no need to run every parallelism value
* Update FlowFlatMapConcatParallelismSpec.scala
---
.../pekko/stream/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..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
@@ -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)
---------------------------------------------------------------------
To unsubscribe, e-mail: [email protected]
For additional commands, e-mail: [email protected]
