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

    • Field Summary

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

      Constructors 
      Constructor Description
      Concat$()  
    • Field Detail

      • MODULE$

        public static final Concat$ MODULE$
        Static reference to the singleton instance of this Scala object.
    • Constructor Detail

      • Concat$

        public Concat$()
    • Method Detail

      • create

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

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

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

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