Packages

object Interleave

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

Value Members

  1. def apply[T](inputPorts: Int, segmentSize: Int, eagerClose: Boolean = false): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new Interleave with the specified number of input ports and given size of elements to take from each input.

    Create a new Interleave with the specified number of input ports and given size of elements to take from each input.

    inputPorts

    number of input ports

    segmentSize

    number of elements to send downstream before switching to next input port

    eagerClose

    if true, interleave completes upstream if any of its upstream completes.