Package akka.stream.scaladsl
Class Unzip<A,B>
- java.lang.Object
-
- akka.stream.stage.GraphStageWithMaterializedValue<S,NotUsed>
-
- akka.stream.stage.GraphStage<FanOutShape2<In,A1,A2>>
-
- akka.stream.scaladsl.UnzipWith2<scala.Tuple2<A,B>,A,B>
-
- akka.stream.scaladsl.Unzip<A,B>
-
- All Implemented Interfaces:
Graph<FanOutShape2<scala.Tuple2<A,B>,A,B>,NotUsed>
public final class Unzip<A,B> extends UnzipWith2<scala.Tuple2<A,B>,A,B>
Takes a stream of pair elements and splits each pair to two output streams.An
Unzip
has onein
port and oneleft
and oneright
output port.'''Emits when''' all of the outputs stop backpressuring and there is an input element available
'''Backpressures when''' any of the outputs backpressure
'''Completes when''' upstream completes
'''Cancels when''' any 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 Unzip()
-
Method Summary
All Methods Static Methods Instance Methods Concrete Methods Modifier and Type Method Description static <A,B>
Unzip<A,B>apply()
Create a newUnzip
.java.lang.String
toString()
-
Methods inherited from class akka.stream.scaladsl.UnzipWith2
createLogic, in, initialAttributes, out0, out1, shape, unzipper
-
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
-
-