Package org.apache.pekko.stream.javadsl

Class ZipWithN

java.lang.Object

org.apache.pekko.stream.javadsl.ZipWithN

public class ZipWithN
extends 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	Description
ZipWithN()

Method Summary

Modifier and Type	Method	Description
static <A, O> Graph<UniformFanInShape<A,O>,NotUsed>	create(Function<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 Details

ZipWithN

public ZipWithN()

Method Details

create

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