Interleave$

java.lang.Object

org.apache.pekko.stream.scaladsl.Interleave$

public class Interleave$ extends Object

Field Summary

Fields

Modifier and Type

Field

Description

static final Interleave$

MODULE$

Static reference to the singleton instance of this Scala object.
Constructor Summary

Constructors

Constructor

Description

Interleave$()
Method Summary

Modifier and Type

Method

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.

<T> boolean

apply$default$3()

Methods inherited from class java.lang.Object
clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

Field Details
- MODULE$
  
  public static final Interleave$ MODULE$
  
  Static reference to the singleton instance of this Scala object.
Constructor Details
- Interleave$
  
  public Interleave$()
Method Details
- 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.
- apply$default$3
  
  public <T> boolean apply$default$3()