Source.zipN
Combine the elements of multiple streams into a stream of sequences.
Source operators
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.