object Unzip

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

Source
Graph.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Unzip
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Value Members

  1. def create[A, B](left: Class[A], right: Class[B]): Graph[FanOutShape2[Pair[A, B], A, B], NotUsed]

    Creates a new Unzip operator with the specified output types.

  2. def create[A, B](): Graph[FanOutShape2[Pair[A, B], A, B], NotUsed]

    Creates a new Unzip operator with the specified output types.