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

=str,doc fixing typo in docs for mapAsync(Unordered) stages

Browse source
This commit is contained in:
Balazs Kossovics 2015-07-16 09:52:58 +02:00
parent 77d3e693c5
commit 77b0c4e9ba
2 changed files with 8 additions and 8 deletions
Download patch file Download diff file Expand all files Collapse all files

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

@ -440,11 +440,11 @@ trait FlowOps[+Out, +Mat] {
* These Futures may complete in any order, but the elements that
* are emitted downstream are in the same order as received from upstream.
*
* If the group by function `f` throws an exception or if the `Future` is completed
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is [[akka.stream.Supervision.Stop]]
* the stream will be completed with failure.
*
* If the group by function `f` throws an exception or if the `Future` is completed
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is [[akka.stream.Supervision.Resume]] or
* [[akka.stream.Supervision.Restart]] the element is dropped and the stream continues.
*
@ -470,11 +470,11 @@ trait FlowOps[+Out, +Mat] {
* as soon as it is ready, i.e. it is possible that the elements are not emitted downstream
* in the same order as received from upstream.
*
* If the group by function `f` throws an exception or if the `Future` is completed
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is [[akka.stream.Supervision.Stop]]
* the stream will be completed with failure.
*
* If the group by function `f` throws an exception or if the `Future` is completed
* If the function `f` throws an exception or if the `Future` is completed
* with failure and the supervision decision is [[akka.stream.Supervision.Resume]] or
* [[akka.stream.Supervision.Restart]] the element is dropped and the stream continues.
*