diff --git a/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala b/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala index ef13ce7f40..bff1bc4588 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala @@ -137,9 +137,9 @@ object Sink { /** * A `Sink` that keeps on collecting incoming elements until upstream terminates. - * As upstream may be unbounded, `Flow[T].take` or the stricter ``Flow[T].limit` (and their variants) + * As upstream may be unbounded, `Flow[T].take` or the stricter `Flow[T].limit` (and their variants) * may be used to ensure boundedness. - * Materializes into a Future` of `Seq[T]` containing all the collected elements. + * Materializes into a `Future` of `Seq[T]` containing all the collected elements. * * See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]] */ diff --git a/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala b/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala index bc02859882..68a9cbaf6f 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala @@ -119,9 +119,9 @@ object Sink { /** * A `Sink` that keeps on collecting incoming elements until upstream terminates. - * As upstream may be unbounded, `Flow[T].take` or the stricter ``Flow[T].limit` (and their variants) + * As upstream may be unbounded, `Flow[T].take` or the stricter `Flow[T].limit` (and their variants) * may be used to ensure boundedness. - * Materializes into a Future` of `Seq[T]` containing all the collected elements. + * Materializes into a `Future` of `Seq[T]` containing all the collected elements. * * See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]] */