Packages

final class Unzip[A, B] extends UnzipWith2[(A, B), A, B]

Combine the elements of multiple streams into a stream of the combined elements.

Source
Graph.scala
Linear Supertypes
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Unzip
  2. UnzipWith2
  3. GraphStage
  4. GraphStageWithMaterializedValue
  5. Graph
  6. AnyRef
  7. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Unzip()

Type Members

  1. type Shape = FanOutShape2[(A, B), A, B]

    Type-level accessor for the shape parameter of this graph.

    Type-level accessor for the shape parameter of this graph.

    Definition Classes
    Graph

Value Members

  1. def addAttributes(attr: Attributes): Graph[FanOutShape2[(A, B), A, B], NotUsed]
    Definition Classes
    Graph
  2. def async: Graph[FanOutShape2[(A, B), A, B], NotUsed]

    Put an asynchronous boundary around this Graph

    Put an asynchronous boundary around this Graph

    Definition Classes
    Graph
  3. def createLogic(inheritedAttributes: Attributes): GraphStageLogic
    Definition Classes
    UnzipWith2GraphStage
  4. final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
  5. def in: Inlet[(A, B)]
    Definition Classes
    UnzipWith2
  6. def initialAttributes: Attributes
  7. final lazy val module: Module

    INTERNAL API.

    INTERNAL API.

    Every materializable element must be backed by a stream layout module

    Definition Classes
    GraphStageWithMaterializedValueGraph
  8. def named(name: String): Graph[FanOutShape2[(A, B), A, B], NotUsed]
    Definition Classes
    Graph
  9. def out0: Outlet[A]
    Definition Classes
    UnzipWith2
  10. def out1: Outlet[B]
    Definition Classes
    UnzipWith2
  11. val shape: FanOutShape2[(A, B), A, B]
    Definition Classes
    UnzipWith2Graph
  12. def toString(): String
    Definition Classes
    UnzipUnzipWith2 → AnyRef → Any
  13. val unzipper: ((A, B)) ⇒ (A, B)
    Definition Classes
    UnzipWith2
  14. final def withAttributes(attr: Attributes): Graph[FanOutShape2[(A, B), A, B], NotUsed]
    Definition Classes
    GraphStageWithMaterializedValueGraph