chore: Require breadth >= 1 in FlattenMerge

apache · Jan 10, 2025 · 90e2df8 · 90e2df8
1 parent 0bf6606
commit 90e2df8
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala b/stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala
@@ -46,6 +46,7 @@ import pekko.util.ccompat.JavaConverters._
  */
 @InternalApi private[pekko] final class FlattenMerge[T, M](val breadth: Int)
     extends GraphStage[FlowShape[Graph[SourceShape[T], M], T]] {
+  require(breadth >= 1, "breadth should >= 1")
   private val in = Inlet[Graph[SourceShape[T], M]]("flatten.in")
   private val out = Outlet[T]("flatten.out")