object Concat

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 apply[T](inputPorts: Int, detachedInputs: Boolean): [UniformFanInShape[T, T], NotUsed]

    Create a new Concat operator that will concatenate two or more streams.

    Create a new Concat operator that will concatenate two or more streams.

    inputPorts

    The number of fan-in input ports

    detachedInputs

    If the ports should be detached (eagerly pull both inputs) useful to avoid deadlocks in graphs with loops

  2. def apply[T](inputPorts: Int = 2): [UniformFanInShape[T, T], NotUsed]

    Create a new Concat.

    Create a new Concat. Note that this for historical reasons creates a "detached" Concat which will eagerly pull each input on materialization and act as a one element buffer for each input.