fix scala 3 compile issue (#684)

apache · Sep 26, 2023 · ac14251 · ac14251
1 parent 201992d
commit ac14251
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala b/stream-typed-tests/src/test/scala/org/apache/pekko/stream/MapAsyncPartitionedSpec.scala
@@ -240,7 +240,7 @@ class MapAsyncPartitionedSpec
   }
 
   it should "fail to create an operator if parallelism is less than 1" in {
-    forAll(Gen.negNum[Int]) { zeroOrNegativeParallelism: Int =>
+    forAll(Gen.negNum[Int]) { (zeroOrNegativeParallelism: Int) =>
       an[IllegalArgumentException] shouldBe thrownBy {
         Source(infiniteStream())
           .mapAsyncPartitionedUnordered(
@@ -392,7 +392,7 @@ class MapAsyncPartitionedSpec
   }
 
   it should "fail to create an operator if parallelism is less than 1" in {
-    forAll(Gen.negNum[Int]) { zeroOrNegativeParallelism: Int =>
+    forAll(Gen.negNum[Int]) { (zeroOrNegativeParallelism: Int) =>
       an[IllegalArgumentException] shouldBe thrownBy {
         Source(infiniteStream())
           .mapAsyncPartitioned(