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

Constructor Summary

Constructors

Constructor and Description
ZipWithN()

Method Summary

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

Constructor Detail

ZipWithN

public ZipWithN()

Method Detail

create

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