public class Interleave$
extends java.lang.Object
Modifier and Type | Field and Description |
---|---|
static Interleave$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
Interleave$() |
Modifier and Type | Method and Description |
---|---|
<T> Graph<UniformFanInShape<T,T>,NotUsed> |
apply(int inputPorts,
int segmentSize,
boolean eagerClose)
Create a new
Interleave with the specified number of input ports and given size of elements
to take from each input. |
public static final Interleave$ MODULE$
public <T> Graph<UniformFanInShape<T,T>,NotUsed> apply(int inputPorts, int segmentSize, boolean eagerClose)
Interleave
with the specified number of input ports and given size of elements
to take from each input.
inputPorts
- number of input portssegmentSize
- number of elements to send downstream before switching to next input porteagerClose
- if true, interleave completes upstream if any of its upstream completes.