Source.zipN

Combine the elements of multiple streams into a stream of sequences.

Source stages

Signature

def zipN[T](sources: immutable.Seq[Source[T, _]]): Source[immutable.Seq[T], NotUsed]

Description

Combine the elements of multiple streams into a stream of sequences.

emits when all of the inputs has an element available

completes when any upstream completes

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.