Package org.apache.pekko.stream.scaladsl

Class Zip<A,B>

java.lang.Object

org.apache.pekko.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>

org.apache.pekko.stream.stage.GraphStage<FanInShape2<A1,A2,O>>

org.apache.pekko.stream.scaladsl.ZipWith2<A,B,scala.Tuple2<A,B>>

org.apache.pekko.stream.scaladsl.Zip<A,B>

All Implemented Interfaces:

Graph<FanInShape2<A,B,scala.Tuple2<A,B>>,NotUsed>

public final class Zip<A,B>
extends ZipWith2<A,B,scala.Tuple2<A,B>>

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

Nested Class Summary

Nested classes/interfaces inherited from interface org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
Zip()

Method Summary

Modifier and Type	Method	Description
static <A, B> Zip<A,B>	apply()	Create a new Zip.
String	toString()

Methods inherited from class org.apache.pekko.stream.scaladsl.ZipWith2

createLogic, in0, in1, initialAttributes, out, shape, zipper

Methods inherited from class org.apache.pekko.stream.stage.GraphStage

createLogicAndMaterializedValue

Methods inherited from class org.apache.pekko.stream.stage.GraphStageWithMaterializedValue

withAttributes

Methods inherited from class java.lang.Object

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

Methods inherited from interface org.apache.pekko.stream.Graph

addAttributes, async, async, async, getAttributes, named

Constructor Details

Zip

public Zip()

Method Details

apply

public static <A,
B> Zip<A,B> apply()

Create a new Zip.

toString

public String toString()

Overrides:

toString in class ZipWith2<A,B,scala.Tuple2<A,B>>