akka.stream.javadsl

Class Zip

java.lang.Object

akka.stream.javadsl.Zip

public class Zip
extends java.lang.Object

Combine the elements of 2 streams into a stream of tuples.

A Zip has a left and a right input port 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
Zip()

Method Summary

Modifier and Type	Method and Description
static <A,B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed>	create() Create a new Zip stage with the specified input types and zipping-function which creates akka.japi.Pairs.

Methods inherited from class java.lang.Object

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

Constructor Detail

Zip

public Zip()

Method Detail

create

public static <A,B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed> create()

Create a new Zip stage with the specified input types and zipping-function which creates akka.japi.Pairs.

Returns:

(undocumented)