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

#19269 doc: Sink.seq is limited to Int.MaxValue

Browse source
This commit is contained in:
Roland Kuhn 2016-01-17 15:04:45 +01:00
parent 2ba8ec1aeb
commit d4b1f07ec0
2 changed files with 4 additions and 0 deletions
Download patch file Download diff file Expand all files Collapse all files

2
akka-stream/src/main/scala/akka/stream/javadsl/Sink.scala
View file

@ -139,6 +139,8 @@ object Sink {
* 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. * 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.
* `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]] * See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]]
*/ */

2
akka-stream/src/main/scala/akka/stream/scaladsl/Sink.scala
View file

@ -142,6 +142,8 @@ object Sink {
* 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. * 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.
* `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]] * See also [[Flow.limit]], [[Flow.limitWeighted]], [[Flow.take]], [[Flow.takeWithin]], [[Flow.takeWhile]]
*/ */