Packages

final class Interleave[T] extends GraphStage[UniformFanInShape[T, T]]

Interleave represents deterministic merge which takes N elements per input stream, in-order of inputs, emits them downstream and then cycles/"wraps-around" the inputs.

Emits when element is available from current input (depending on phase)

Backpressures when downstream backpressures

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

Cancels when downstream cancels

Source
Graph.scala
Linear Supertypes
GraphStage[UniformFanInShape[T, T]], GraphStageWithMaterializedValue[UniformFanInShape[T, T], NotUsed], Graph[UniformFanInShape[T, T], NotUsed], AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. Interleave
  2. GraphStage
  3. GraphStageWithMaterializedValue
  4. Graph
  5. AnyRef
  6. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Instance Constructors

  1. new Interleave(inputPorts: Int, segmentSize: Int, eagerClose: Boolean)

Type Members

  1. type Shape = UniformFanInShape[T, T]

    Type-level accessor for the shape parameter of this graph.

    Type-level accessor for the shape parameter of this graph.

    Definition Classes
    Graph

Value Members

  1. def addAttributes(attr: Attributes): Graph[UniformFanInShape[T, T], NotUsed]
    Definition Classes
    Graph
  2. def async: Graph[UniformFanInShape[T, T], NotUsed]

    Put an asynchronous boundary around this Graph

    Put an asynchronous boundary around this Graph

    Definition Classes
    Graph
  3. def createLogic(inheritedAttributes: Attributes): GraphStageLogic
    Definition Classes
    Interleave → GraphStage
  4. final def createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
    Definition Classes
    GraphStage → GraphStageWithMaterializedValue
  5. val eagerClose: Boolean
  6. val in: IndexedSeq[Inlet[T]]
  7. val inputPorts: Int
  8. final lazy val module: Module

    INTERNAL API.

    INTERNAL API.

    Every materializable element must be backed by a stream layout module

    Definition Classes
    GraphStageWithMaterializedValue → Graph
  9. def named(name: String): Graph[UniformFanInShape[T, T], NotUsed]
    Definition Classes
    Graph
  10. val out: Outlet[T]
  11. val segmentSize: Int
  12. val shape: UniformFanInShape[T, T]
    Definition Classes
    Interleave → Graph
  13. def toString(): String
    Definition Classes
    Interleave → AnyRef → Any
  14. final def withAttributes(attr: Attributes): Graph[UniformFanInShape[T, T], NotUsed]
    Definition Classes
    GraphStageWithMaterializedValue → Graph