We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent 0bf6606 commit 18e98d4Copy full SHA for 18e98d4
stream/src/main/scala/org/apache/pekko/stream/impl/fusing/StreamOfStreams.scala
@@ -46,6 +46,7 @@ import pekko.util.ccompat.JavaConverters._
46
*/
47
@InternalApi private[pekko] final class FlattenMerge[T, M](val breadth: Int)
48
extends GraphStage[FlowShape[Graph[SourceShape[T], M], T]] {
49
+ require(breadth >= 1, "breadth should >= 1")
50
private val in = Inlet[Graph[SourceShape[T], M]]("flatten.in")
51
private val out = Outlet[T]("flatten.out")
52
0 commit comments