chore: Require parallelism >= 1 in MapAsync and MapAsyncUnordered (#1700

)
apache · Jan 10, 2025 · b160861 · b160861
1 parent 18e98d4
commit b160861
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/Ops.scala
@@ -1281,6 +1281,7 @@ private[stream] object Collect {
  */
 @InternalApi private[pekko] final case class MapAsync[In, Out](parallelism: Int, f: In => Future[Out])
     extends GraphStage[FlowShape[In, Out]] {
+  require(parallelism >= 1, "parallelism must be at least 1")
 
   import MapAsync._
 
@@ -1388,6 +1389,7 @@ private[stream] object Collect {
  */
 @InternalApi private[pekko] final case class MapAsyncUnordered[In, Out](parallelism: Int, f: In => Future[Out])
     extends GraphStage[FlowShape[In, Out]] {
+  require(parallelism >= 1, "parallelism must be at least 1")
 
   private val in = Inlet[In]("MapAsyncUnordered.in")
   private val out = Outlet[Out]("MapAsyncUnordered.out")