Package org.apache.pekko.stream.scaladsl

Class Unzip<A,B>

java.lang.Object

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

org.apache.pekko.stream.stage.GraphStage<FanOutShape2<In,A1,A2>>

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

org.apache.pekko.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 one in port and one left and one right 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 org.apache.pekko.stream.Graph

Graph.GraphMapMatVal<S extends Shape,M>

Constructor Summary

Constructors

Constructor	Description
Unzip()

Method Summary

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

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

createLogic, in, initialAttributes, out0, out1, shape, unzipper

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

Unzip

public Unzip()

Method Details

apply

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

Create a new Unzip.

toString

public String toString()

Overrides:

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