Sink.seq

Collect values emitted from the stream into a collection.

Sink operators

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