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

One small step for mankind but a pretty big one for the stage overview

Browse source
This commit is contained in:
Johan Andrén 2016-02-05 14:37:47 +01:00
parent cdae861de9
commit 62020f44a8
2 changed files with 599 additions and 148 deletions
Download patch file Download diff file Expand all files Collapse all files

745
akka-docs/rst/general/stream/stages-overview.rst
View file

File diff suppressed because it is too large Load diff

2
akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala
View file

@ -970,7 +970,7 @@ trait FlowOps[+Out, +Mat] {
* until the subscriber is ready to accept them. For example a batch step might store received elements in * until the subscriber is ready to accept them. For example a batch step might store received elements in
* an array up to the allowed max limit if the upstream publisher is faster. * an array up to the allowed max limit if the upstream publisher is faster.
* *
* This element only rolls up elements if the upstream is faster, but if the downstream is faster it will not * This only rolls up elements if the upstream is faster, but if the downstream is faster it will not
* duplicate elements. * duplicate elements.
* *
* '''Emits when''' downstream stops backpressuring and there is an aggregated element available * '''Emits when''' downstream stops backpressuring and there is an aggregated element available