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

Merge pull request #19063 from akka/wip-fusable-stream-of-streams-RK

Browse source 
!str #15089 add flatMapMerge
This commit is contained in:
Konrad Malawski 2015-12-02 15:42:26 +01:00
commit cf6592f5c1
13 changed files with 485 additions and 74 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-docs-dev/rst/java/code/docs/MigrationsJava.java
View file

@ -147,8 +147,8 @@ public class MigrationsJava {
//#flatMapConcat
Flow.<Source<Integer, BoxedUnit>>create().
<Integer>flatMapConcat(new Function<Source<Integer, BoxedUnit>, Source<Integer, ?>>(){
@Override public Source<Integer, ?> apply(Source<Integer, BoxedUnit> param) throws Exception {
<Integer, BoxedUnit>flatMapConcat(new Function<Source<Integer, BoxedUnit>, Source<Integer, BoxedUnit>>(){
@Override public Source<Integer, BoxedUnit> apply(Source<Integer, BoxedUnit> param) throws Exception {
return param;
}
});

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

@ -105,7 +105,8 @@ prefixAndTail the configured number of prefix elements are available. E
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
flatMapConcat the current consumed substream has an element available downstream backpressures upstream completes and all consumed substreams complete
flatMapMerge one of the currently consumed substreams has an element available downstream backpressures upstream completes and all consumed substreams complete
===================== ========================================================================================================================================= ============================================================================================================================== =====================================================================================
Fan-in stages