Class MergeLatest<T,​M>

    • Constructor Detail

      • MergeLatest

        public MergeLatest​(int inputPorts,
                           boolean eagerClose,
                           scala.Function1<java.lang.Object,​M> buildElem)
    • Method Detail

      • apply

        public static <T> GraphStage<UniformFanInShape<T,​scala.collection.immutable.List<T>>> apply​(int inputPorts,
                                                                                                          boolean eagerComplete)
        Create a new MergeLatest with the specified number of input ports.

        Parameters:
        inputPorts - number of input ports
        eagerComplete - if true, the merge latest will complete as soon as one of its inputs completes.
        Returns:
        (undocumented)
      • apply$default$2

        public static <T> boolean apply$default$2()
      • named

        public static Graph<S,​M> named​(java.lang.String name)
      • async

        public static Graph<S,​M> async()
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher)
      • async

        public static Graph<S,​M> async​(java.lang.String dispatcher,
                                             int inputBufferSize)
      • addAttributes

        public static Graph<S,​M> addAttributes​(Attributes attr)
      • initialAttributes

        protected static Attributes initialAttributes()
      • withAttributes

        public static final Graph<S,​M> withAttributes​(Attributes attr)
      • createLogicAndMaterializedValue

        public static final scala.Tuple2<GraphStageLogic,​NotUsed> createLogicAndMaterializedValue​(Attributes inheritedAttributes)
      • inputPorts

        public int inputPorts()
      • eagerClose

        public boolean eagerClose()
      • in

        public scala.collection.immutable.IndexedSeq<Inlet<T>> in()
      • shape

        public UniformFanInShape<T,​M> shape()
        Description copied from interface: Graph
        The shape of a graph is all that is externally visible: its inlets and outlets.
        Returns:
        (undocumented)
      • toString

        public java.lang.String toString()
        Overrides:
        toString in class java.lang.Object