Package org.apache.pekko.stream.scaladsl

Class Unzip$

java.lang.Object

org.apache.pekko.stream.scaladsl.Unzip$

public class Unzip$
extends 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 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

Field Summary

Fields

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

Constructor Summary

Constructors

Constructor	Description
Unzip$()

Method Summary

Modifier and Type	Method	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 Details

MODULE$

public static final Unzip$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

Unzip$

public Unzip$()

Method Details

apply

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

Create a new Unzip.