object Zip

Combine the elements of 2 streams into a stream of tuples.

A Zip has a left and a right input port and one out port

Emits when all of the inputs has an element available

Backpressures when downstream backpressures

Completes when any upstream completes

Cancels when downstream cancels

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

Value Members

  1. def create[A, B]: Graph[FanInShape2[A, B, Pair[A, B]], NotUsed]

    Create a new Zip operator with the specified input types and zipping-function which creates akka.japi.Pairs.