akka.stream.javadsl

Class ZipWithN$

java.lang.Object

akka.stream.javadsl.ZipWithN$

public class ZipWithN$
extends java.lang.Object

Combine the elements of multiple streams into a stream of lists using a combiner function.

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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor and Description
ZipWithN$()

Method Summary

Modifier and Type	Method and Description
<A,O> Graph<UniformFanInShape<A,O>,NotUsed>	create(Function<java.util.List<A>,O> zipper, int n)

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final ZipWithN$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

ZipWithN$

public ZipWithN$()

Method Detail

create

public <A,O> Graph<UniformFanInShape<A,O>,NotUsed> create(Function<java.util.List<A>,O> zipper,
                                                          int n)