Package akka.stream.scaladsl
Class Zip<A,B>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<FanInShape2<A1,A2,O>>
-
- akka.stream.scaladsl.ZipWith2<A,B,scala.Tuple2<A,B>>
-
- akka.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 aleft
and aright
input port and oneout
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 akka.stream.Graph
Graph.GraphMapMatVal<S extends Shape,M>
-
-
Constructor Summary
Constructors Constructor Description Zip()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <A,B>
Zip<A,B>apply()
Create a newZip
.java.lang.String
toString()
-
Methods inherited from class akka.stream.scaladsl.ZipWith2
createLogic, in0, in1, initialAttributes, out, shape, zipper
-
Methods inherited from class akka.stream.stage.GraphStage
createLogicAndMaterializedValue
-
Methods inherited from class akka.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 akka.stream.Graph
addAttributes, async, async, async, getAttributes, named
-
-