Zip

java.lang.Object

org.apache.pekko.stream.javadsl.Zip

public class Zip extends 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

Description

Zip()
Method Summary

Modifier and Type

Method

Description

static <A, B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed>

create()

Create a new Zip operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Constructor Details
- Zip
  
  public Zip()
Method Details
- create
  
  public static <A, B> Graph<FanInShape2<A,B,Pair<A,B>>,NotUsed> create()
  
  Create a new Zip operator with the specified input types and zipping-function which creates org.apache.pekko.japi.Pairs.