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

Merge pull request #17196 from ktoso/wip-splitAfter-ktoso

Browse source 
+str #16885 add splitAfter
This commit is contained in:
Konrad Malawski 2015-06-01 16:13:05 +02:00
commit ce68659473
12 changed files with 709 additions and 216 deletions
Download patch file Download diff file Expand all files Collapse all files

17
akka-docs-dev/rst/stages-overview.rst
View file

@ -95,14 +95,15 @@ nested streams and turn them into a stream of elements instead (flattening).
**It is currently not possible to build custom nesting or flattening stages**
===================== ========================================================================================================================= ============================================================================================================================== =====================================================================================
Stage Emits when Backpressures when Completes when
===================== ========================================================================================================================= ============================================================================================================================== =====================================================================================
prefixAndTail the configured number of prefix elements are available. Emits this prefix, and the rest as a substream downstream backpressures or substream backpressures prefix elements has been consumed and substream has been consumed
groupBy an element for which the grouping function returns a group that has not yet been created. Emits the new group there is an element pending for a group whose substream backpressures upstream completes [3]_
splitWhen an element for which the provided predicate is true, opening and emitting a new substream for subsequent elements there is an element pending for the next substream, but the previous is not fully consumed yet, or the substream backpressures upstream completes [3]_
flatten (Concat) the current consumed substream has an element available downstream backpressures upstream completes and all consumed substreams complete
===================== ========================================================================================================================= ============================================================================================================================== =====================================================================================
===================== ========================================================================================================================================= ============================================================================================================================== =====================================================================================
Stage Emits when Backpressures when Completes when
===================== ========================================================================================================================================= ============================================================================================================================== =====================================================================================
prefixAndTail the configured number of prefix elements are available. Emits this prefix, and the rest as a substream downstream backpressures or substream backpressures prefix elements has been consumed and substream has been consumed
groupBy an element for which the grouping function returns a group that has not yet been created. Emits the new group there is an element pending for a group whose substream backpressures upstream completes [3]_
splitWhen an element for which the provided predicate is true, opening and emitting a new substream for subsequent elements there is an element pending for the next substream, but the previous is not fully consumed yet, or the substream backpressures upstream completes [3]_
splitAfter an element passes through. When the provided predicate is true it emitts the element * and opens a new substream for subsequent element there is an element pending for the next substream, but the previous is not fully consumed yet, or the substream backpressures upstream completes [3]_
flatten (Concat) the current consumed substream has an element available downstream backpressures upstream completes and all consumed substreams complete
===================== ========================================================================================================================================= ============================================================================================================================== =====================================================================================
Fan-in stages
^^^^^^^^^^^^^