Sink.seq
Collect values emitted from the stream into a collection.
Signature
Description
Collect values emitted from the stream into a collection, the collection is available through a Future
or which completes when the stream completes. Note that the collection is bounded to Int.MaxValue
, if more element are emitted the sink will cancel the stream
Example
Given a stream of numbers we can collect the numbers into a collection with the seq
operator
- Scala
-
source
val source = Source(1 to 3) val result = source.runWith(Sink.seq[Int]) val seq = result.futureValue seq.foreach(println) // will print // 1 // 2 // 3
- Java
Reactive Streams semantics
cancels If too many values are collected