Package org.apache.pekko.stream.javadsl

Class Interleave

java.lang.Object

org.apache.pekko.stream.javadsl.Interleave

public class Interleave
extends Object

Constructor Summary

Constructors

Constructor	Description
Interleave()

Method Summary

Modifier and Type	Method	Description
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(int inputPorts, int segmentSize)	Create a new Interleave with the specified number of input ports and given size of elements to take from each input, with eagerClose set to false.
static <T> Graph<UniformFanInShape<T,T>,NotUsed>	create(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

Constructor Details

Interleave

public Interleave()

Method Details

create

public static <T>
Graph<UniformFanInShape<T,T>,NotUsed> create(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.

create

public static <T>
Graph<UniformFanInShape<T,T>,NotUsed> create(int inputPorts,
 int segmentSize)

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

Parameters:

inputPorts - number of input ports

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