Packages

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 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

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. All

Value Members

  1. def apply[A, B](): Unzip[A, B]

    Create a new Unzip.