From ac14251912804d27ea9f1508191a12016cec6b6d Mon Sep 17 00:00:00 2001 From: PJ Fanning Date: Tue, 26 Sep 2023 14:10:06 +0100 Subject: [PATCH] fix scala 3 compile issue (#684) --- .../org/apache/pekko/stream/MapAsyncPartitionedSpec.scala | 4 ++-- 1 file changed, 2 insertions(+), 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 index d70e7fabce5..6b46a5dc49a 100644 --- 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(