raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

+doc stages-overview entry for partition stage #21020 (#21073)

Browse source
This commit is contained in:
Stefano Bonetti 2016-07-30 10:04:56 +01:00 • committed by Konrad Malawski
parent 57b77d15af
commit 4e36541350
2 changed files with 22 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

11
akka-docs/rst/java/stream/stages-overview.rst
View file

@ -1217,6 +1217,17 @@ Fan-out the stream to several streams. Each upstream element is emitted to the f
**completes** when upstream completes **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 Watching status stages
---------------------- ----------------------

11
akka-docs/rst/scala/stream/stages-overview.rst
View file

@ -1208,6 +1208,17 @@ Fan-out the stream to several streams. Each upstream element is emitted to the f
**completes** when upstream completes **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 Watching status stages
---------------------- ----------------------