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 a6ff990206..8e1f57d15e 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Flow.scala @@ -484,8 +484,8 @@ final class Flow[In, Out, Mat](delegate: scaladsl.Flow[In, Out, Mat]) extends Gr new Flow(delegate.map(f.apply)) /** - * Similar to [[map]], however does not modify the passed through element, the returned value is ignored. - * This is a simplified version of `wireTap(Sink)`, which you may use to wireTap a Sink onto this stream. + * This is a simplified version of `wireTap(Sink)` that takes only a simple procedure. + * Elements will be passed into this "side channel" function, and any of its results will be ignored. * * This operation is useful for inspecting the passed through element, usually by means of side-effecting * operations (such as `println`, or emitting metrics), for each element without having to modify it. diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala index 3199d9586b..6cc27fe17d 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Source.scala @@ -1073,7 +1073,8 @@ final class Source[Out, Mat](delegate: scaladsl.Source[Out, Mat]) extends Graph[ new Source(delegate.map(f.apply)) /** - * Similar to [[map]], however does not modify the passed through element, the returned value is ignored. + * This is a simplified version of `wireTap(Sink)` that takes only a simple procedure. + * Elements will be passed into this "side channel" function, and any of its results will be ignored. * * This operation is useful for inspecting the passed through element, usually by means of side-effecting * operations (such as `println`, or emitting metrics), for each element without having to modify it. diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala b/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala index b09ac8a3cf..c40ea9fbcc 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/SubFlow.scala @@ -136,8 +136,8 @@ class SubFlow[In, Out, Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Flow[I new SubFlow(delegate.map(f.apply)) /** - * Similar to [[map]], however does not modify the passed through element, the returned value is ignored. - * This is a simplified version of `wireTap(Sink)`, which you may use to wireTap a Sink onto this stream. + * This is a simplified version of `wireTap(Sink)` that takes only a simple procedure. + * Elements will be passed into this "side channel" function, and any of its results will be ignored. * * This operation is useful for inspecting the passed through element, usually by means of side-effecting * operations (such as `println`, or emitting metrics), for each element without having to modify it. diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala b/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala index 6770ceffbd..3672c38b75 100755 --- a/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/SubSource.scala @@ -129,8 +129,8 @@ class SubSource[Out, Mat](delegate: scaladsl.SubFlow[Out, Mat, scaladsl.Source[O new SubSource(delegate.map(f.apply)) /** - * Similar to [[map]], however does not modify the passed through element, the returned value is ignored. - * This is a simplified version of `wireTap(Sink)`, which you may use to wireTap a Sink onto this stream. + * This is a simplified version of `wireTap(Sink)` that takes only a simple procedure. + * Elements will be passed into this "side channel" function, and any of its results will be ignored. * * This operation is useful for inspecting the passed through element, usually by means of side-effecting * operations (such as `println`, or emitting metrics), for each element without having to modify it. 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 007bb942f2..861f71355d 100755 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Flow.scala @@ -767,8 +767,8 @@ trait FlowOps[+Out, +Mat] { def map[T](f: Out ⇒ T): Repr[T] = via(Map(f)) /** - * Similar to [[map]], however does not modify the passed through element, the returned value is ignored. - * This is a simplified version of `wireTap(Sink)`, which you may use to wireTap a Sink onto this stream. + * This is a simplified version of `wireTap(Sink)` that takes only a simple function. + * Elements will be passed into this "side channel" function, and any of its results will be ignored. * * This operation is useful for inspecting the passed through element, usually by means of side-effecting * operations (such as `println`, or emitting metrics), for each element without having to modify it.