Package org.apache.pekko.stream.javadsl

Class Interleave$

java.lang.Object
org.apache.pekko.stream.javadsl.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>
    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.
    <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

  • 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

    • create

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