diff --git a/akka-docs/rst/java/stream/stages-overview.rst b/akka-docs/rst/java/stream/stages-overview.rst index 6373eb8e70..053fe2c77b 100644 --- a/akka-docs/rst/java/stream/stages-overview.rst +++ b/akka-docs/rst/java/stream/stages-overview.rst @@ -1217,6 +1217,17 @@ Fan-out the stream to several streams. Each upstream element is emitted to the f **completes** when upstream completes +partition +^^^^^^^^^ +Fan-out the stream to several streams. Each upstream element is emitted to one downstream consumer according to the +partitioner function applied to the element. + +**emits** when the chosen output stops backpressuring and there is an input element available + +**backpressures** when the chosen output backpressures + +**completes** when upstream completes and no output is pending + Watching status stages ---------------------- diff --git a/akka-docs/rst/scala/stream/stages-overview.rst b/akka-docs/rst/scala/stream/stages-overview.rst index dcae95bc47..d5f10f0d52 100644 --- a/akka-docs/rst/scala/stream/stages-overview.rst +++ b/akka-docs/rst/scala/stream/stages-overview.rst @@ -1208,6 +1208,17 @@ Fan-out the stream to several streams. Each upstream element is emitted to the f **completes** when upstream completes +partition +^^^^^^^^^ +Fan-out the stream to several streams. Each upstream element is emitted to one downstream consumer according to the +partitioner function applied to the element. + +**emits** when the chosen output stops backpressuring and there is an input element available + +**backpressures** when the chosen output backpressures + +**completes** when upstream completes and no output is pending + Watching status stages ----------------------