Class Concat$


  • public class Concat$
    extends java.lang.Object
    • 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

      • apply

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> apply​(int inputPorts)
        Create a new Concat. Note that this for historical reasons creates a "detached" Concat which will eagerly pull each input on materialization and act as a one element buffer for each input.
      • apply

        public <T> Graph<UniformFanInShape<T,​T>,​NotUsed> apply​(int inputPorts,
                                                                           boolean detachedInputs)
        Create a new Concat operator that will concatenate two or more streams.
        Parameters:
        inputPorts - The number of fan-in input ports
        detachedInputs - If the ports should be detached (eagerly pull both inputs) useful to avoid deadlocks in graphs with loops
        Returns:
      • apply$default$1

        public <T> int apply$default$1()