Sink.seq

Collect values emitted from the stream into a collection.

Sink stages

Signature

def seq[T]: Sink[T, Future[immutable.Seq[T]]]

Description

Collect values emitted from the stream into a collection, the collection is available through a Future CompletionStage or which completes when the stream completes. Note that the collection is bounded to Int.MaxValue Integer.MAX_VALUE, if more element are emitted the sink will cancel the stream

cancels If too many values are collected

Found an error in this documentation? The source code for this page can be found here. Please feel free to edit and contribute a pull request.