From d4b1f07ec091de2bae6442b393715d5e845973be Mon Sep 17 00:00:00 2001 From: Roland Kuhn Date: Sun, 17 Jan 2016 15:04:45 +0100 Subject: [PATCH] #19269 doc: Sink.seq is limited to Int.MaxValue --- akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala | 2 ++ akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala | 2 ++ 2 files changed, 4 insertions(+) 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 6b53652162..6cb19738f9 100644 --- a/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala +++ b/akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala @@ -139,6 +139,8 @@ object Sink { * 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. + * `List` is limited to `Integer.MAX_VALUE` elements, this Sink will cancel the stream + * after having received that many 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 3562feec94..2674e7d292 100644 --- a/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala +++ b/akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala @@ -142,6 +142,8 @@ object Sink { * 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. + * `Seq` is limited to `Int.MaxValue` elements, this Sink will cancel the stream + * after having received that many elements. * * See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]] */