object Merge

Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

Emits when one of the inputs has an element available

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)

Cancels when downstream cancels

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

Value Members

  1. def create[T](clazz: Class[T], inputPorts: Int, eagerComplete: Boolean): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new Merge operator with the specified output type.

    Create a new Merge operator with the specified output type.

    eagerComplete

    set to true in order to make this operator eagerly finish as soon as one of its inputs completes

  2. def create[T](inputPorts: Int, eagerComplete: Boolean): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new Merge operator with the specified output type.

    Create a new Merge operator with the specified output type.

    eagerComplete

    set to true in order to make this operator eagerly finish as soon as one of its inputs completes

  3. def create[T](clazz: Class[T], inputPorts: Int): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new Merge operator with the specified output type.

  4. def create[T](inputPorts: Int): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new Merge operator with the specified output type.