public class ZipWithN$
extends java.lang.Object
A ZipWithN
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
Modifier and Type | Field and Description |
---|---|
static ZipWithN$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
ZipWithN$() |
Modifier and Type | Method and Description |
---|---|
<A,O> Graph<UniformFanInShape<A,O>,NotUsed> |
create(Function<java.util.List<A>,O> zipper,
int n) |
public static final ZipWithN$ MODULE$
public <A,O> Graph<UniformFanInShape<A,O>,NotUsed> create(Function<java.util.List<A>,O> zipper, int n)