Package org.apache.pekko.stream.javadsl

Class Concat

  • public class Concat
extends java.lang.Object
    Takes two streams and outputs an output stream formed from the two input streams by consuming one stream first emitting all of its elements, then consuming the second stream emitting all of its elements.

    '''Emits when''' the current stream has an element available; if the current input completes, it tries the next one

    '''Backpressures when''' downstream backpressures

    '''Completes when''' all upstreams complete

    '''Cancels when''' downstream cancels

    • Constructor Summary

      Constructors 
      Constructor Description
      Concat()  

    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create()
      Create a new anonymous Concat operator with the specified input types.
      static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputCount)
      Create a new anonymous Concat operator with the specified input types.
      static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputCount, boolean detachedInputs)
      Create a new anonymous Concat operator with the specified input types.
      static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz)
      Create a new anonymous Concat operator with the specified input types.

      • Methods inherited from class java.lang.Object

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

    • Constructor Detail

      • Concat

        public Concat()

    • Method Detail

      • create

        public static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create()
        Create a new anonymous Concat operator with the specified input types.

      • create

        public static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputCount)
        Create a new anonymous Concat operator with the specified input types.

      • create

        public static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(int inputCount,
                                                                           boolean detachedInputs)
        Create a new anonymous Concat operator with the specified input types.

      • create

        public static <T> Graph<UniformFanInShape<T,​T>,​NotUsed> create​(java.lang.Class<T> clazz)
        Create a new anonymous Concat operator with the specified input types.