akka.stream.scaladsl

Class Interleave$

java.lang.Object

akka.stream.scaladsl.Interleave$

public class Interleave$
extends java.lang.Object

Field Summary

Fields

Modifier and Type	Field and Description
static Interleave$	MODULE$ Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor and Description
Interleave$()

Method Summary

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.

Methods inherited from class java.lang.Object

clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Detail

MODULE$

public static final Interleave$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Detail

Interleave$

public Interleave$()

Method Detail

apply

public <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.

Parameters:

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.

Returns:

(undocumented)