Package org.apache.pekko.stream.scaladsl

Class Merge$

java.lang.Object
org.apache.pekko.stream.scaladsl.Merge$
public class Merge$ extends Object

  • Field Summary

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

  • Constructor Summary

    Constructors
    Constructor
    Description
    Merge$()
     

  • Method Summary

    Modifier and Type
    Method
    Description
    <T> Merge<T>
    apply(int inputPorts, boolean eagerComplete)
    Create a new Merge with the specified number of input ports.
    <T> boolean
    apply$default$2()
     

    Methods inherited from class java.lang.Object

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

  • Field Details

    • MODULE$

      public static final Merge$ MODULE$
      Static reference to the singleton instance of this Scala object.

  • Constructor Details

    • Merge$

      public Merge$()

  • Method Details

    • apply

      public <T> Merge<T> apply(int inputPorts, boolean eagerComplete)
      Create a new Merge with the specified number of input ports.

      Parameters:
      inputPorts - number of input ports
      eagerComplete - if true, the merge will complete as soon as one of its inputs completes.

    • apply$default$2

      public <T> boolean apply$default$2()