Package org.apache.pekko.stream.javadsl

Class Merge$

  • public class Merge$
extends java.lang.Object
    Merge several streams, taking elements as they arrive from input streams (picking randomly when several have elements ready).

    '''Emits when''' one of the inputs has an element available

    '''Backpressures when''' downstream backpressures

    '''Completes when''' all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)

    '''Cancels when''' downstream cancels

    • Field Summary

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

    • Constructor Summary

      Constructors 
      Constructor Description
      Merge$()  

    • Method Summary

      All Methods Instance Methods Concrete Methods 
      Modifier and Type Method Description
      <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputPorts)
      Create a new Merge operator with the specified output type.
      <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputPorts, boolean eagerComplete)
      Create a new Merge operator with the specified output type.
      <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz, int inputPorts)
      Create a new Merge operator with the specified output type.
      <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz, int inputPorts, boolean eagerComplete)
      Create a new Merge operator with the specified output type.

      • Methods inherited from class java.lang.Object

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

    • Field Detail

      • MODULE$

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

    • Constructor Detail

      • Merge$

        public Merge$()

    • Method Detail

      • create

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputPorts)
        Create a new Merge operator with the specified output type.

      • create

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz,
                                                                    int inputPorts)
        Create a new Merge operator with the specified output type.

      • create

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputPorts,
                                                                    boolean eagerComplete)
        Create a new Merge operator with the specified output type.

        Parameters:
        eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes

      • create

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz,
                                                                    int inputPorts,
                                                                    boolean eagerComplete)
        Create a new Merge operator with the specified output type.

        Parameters:
        eagerComplete - set to true in order to make this operator eagerly finish as soon as one of its inputs completes