object Concat

Takes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.

Emits when the current stream has an element available; if the current input completes, it tries the next one

Backpressures when downstream backpressures

Completes when all upstreams complete

Cancels when downstream cancels

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

Value Members

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

    Create a new anonymous Concat operator with the specified input types.

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

    Create a new anonymous Concat operator with the specified input types.

  3. def create[T](inputCount: Int): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new anonymous Concat operator with the specified input types.

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

    Create a new anonymous Concat operator with the specified input types.