Unzip$

java.lang.Object

org.apache.pekko.stream.javadsl.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 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

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> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed>

create()

Creates a new Unzip operator with the specified output types.

<A, B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed>

create(Class<A> left, Class<B> right)

Creates a new Unzip operator with the specified output types.

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
- create
  
  public <A, B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> create()
  
  Creates a new Unzip operator with the specified output types.
- create
  
  public <A, B> Graph<FanOutShape2<Pair<A,B>,A,B>,NotUsed> create(Class<A> left, Class<B> right)
  
  Creates a new Unzip operator with the specified output types.