Skip to content

Commit 741e8fc

Browse files
authored
no need to run every parallelism value (#2829)
* no need to run every parallelism value * Update FlowFlatMapConcatParallelismSpec.scala
1 parent 292e4cf commit 741e8fc

1 file changed

Lines changed: 6 additions & 3 deletions

File tree

stream-tests/src/test/scala/org/apache/pekko/stream/scaladsl/FlowFlatMapConcatParallelismSpec.scala

Lines changed: 6 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -47,9 +47,12 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec("""
4747
val toSeq = Flow[Int].grouped(1000).toMat(Sink.head)(Keep.right)
4848

4949
class BoomException extends RuntimeException("BOOM~~") with NoStackTrace
50+
51+
val checkValues = List(1, 2, 4, 8, 16, 32, 64, 128)
52+
5053
"A flatMapConcat" must {
5154

52-
for (i <- 1 until 129) {
55+
for (i <- checkValues) {
5356
s"work with value presented sources with parallelism: $i" in {
5457
Source(
5558
List(
@@ -98,7 +101,7 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec("""
98101
(sum, seq)
99102
}
100103

101-
for (i <- 1 until 129) {
104+
for (i <- checkValues) {
102105
s"work with generated value presented sources with parallelism: $i " in {
103106
val (sum, sources @ _) = generateRandomValuePresentedSources(100000)
104107
Source(sources)
@@ -109,7 +112,7 @@ class FlowFlatMapConcatParallelismSpec extends StreamSpec("""
109112
}
110113
}
111114

112-
for (i <- 1 until 129) {
115+
for (i <- checkValues) {
113116
s"work with generated value sequenced sources with parallelism: $i " in {
114117
val (sum, sources @ _) = generateSequencedValuePresentedSources(100000)
115118
Source(sources)

0 commit comments

Comments
 (0)