From 77b0c4e9ba9e048e06a7906f8c633c0953f864fb Mon Sep 17 00:00:00 2001 From: Balazs Kossovics Date: Thu, 16 Jul 2015 09:52:58 +0200 Subject: [PATCH] =str,doc fixing typo in docs for mapAsync(Unordered) stages --- akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala | 8 ++++---- .../src/main/scala/akka/stream/scaladsl/Flow.scala | 8 ++++---- 2 files changed, 8 insertions(+), 8 deletions(-) diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala index e157a93b59..0c1a629caf 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -246,11 +246,11 @@ class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Graph * downstream may run in parallel and 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. * @@ -276,11 +276,11 @@ class Flow[-In, +Out, +Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Graph * 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. * diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala index 721f37ad86..f9db52ae46 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -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. *