File tree 1 file changed +2
-0
lines changed
stream/src/main/scala/org/apache/pekko/stream/impl/fusing
1 file changed +2
-0
lines changed Original file line number Diff line number Diff line change @@ -1281,6 +1281,7 @@ private[stream] object Collect {
1281
1281
*/
1282
1282
@ InternalApi private [pekko] final case class MapAsync [In , Out ](parallelism : Int , f : In => Future [Out ])
1283
1283
extends GraphStage [FlowShape [In , Out ]] {
1284
+ require(parallelism >= 1 , " parallelism must be at least 1" )
1284
1285
1285
1286
import MapAsync ._
1286
1287
@@ -1388,6 +1389,7 @@ private[stream] object Collect {
1388
1389
*/
1389
1390
@ InternalApi private [pekko] final case class MapAsyncUnordered [In , Out ](parallelism : Int , f : In => Future [Out ])
1390
1391
extends GraphStage [FlowShape [In , Out ]] {
1392
+ require(parallelism >= 1 , " parallelism must be at least 1" )
1391
1393
1392
1394
private val in = Inlet [In ](" MapAsyncUnordered.in" )
1393
1395
private val out = Outlet [Out ](" MapAsyncUnordered.out" )
You can’t perform that action at this time.
0 commit comments