object ZipWithN

Combine the elements of multiple streams into a stream of lists using a combiner function.

A ZipWithN has a n input ports 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
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. ZipWithN
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def create[A, O](zipper: Function[List[A], O], n: Int): Graph[UniformFanInShape[A, O], NotUsed]