akka.stream.scaladsl

Class Unzip$

java.lang.Object

akka.stream.scaladsl.Unzip$

public class Unzip$
extends java.lang.Object

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 stops backpressuring and there is an input element available

'''Backpressures when''' any of the outputs backpressures

'''Completes when''' upstream completes

'''Cancels when''' any downstream cancels

Field Summary

Fields

Modifier and Type	Field and Description
static Unzip$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Unzip$()

Method Summary

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

Methods inherited from class java.lang.Object

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

Field Detail

MODULE$

public static final Unzip$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Unzip$

public Unzip$()

Method Detail

apply

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

Create a new Unzip.

Returns:

(undocumented)