Package org.apache.pekko.stream.javadsl

Class ZipN

java.lang.Object

org.apache.pekko.stream.javadsl.ZipN

public class ZipN
extends Object

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

A ZipN has a n input ports and one out port

'''Emits when''' all of the inputs has an element available

'''Backpressures when''' downstream backpressures

'''Completes when''' any upstream completes

'''Cancels when''' downstream cancels

Constructor Summary

Constructors

Constructor	Description
ZipN()

Method Summary

Modifier and Type	Method	Description
static <A> Graph<UniformFanInShape<A,List<A>>,NotUsed>	create(int n)

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details

ZipN

public ZipN()

Method Details

create

public static <A>
Graph<UniformFanInShape<A,List<A>>,NotUsed> create(int n)