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

Field Summary

Fields

Modifier and Type	Field	Description
static final ZipN$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
ZipN$()

Method Summary

Modifier and Type	Method	Description
<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

Field Details

MODULE$

public static final ZipN$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

ZipN$

public ZipN$()

Method Details

create

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