Class MergeLatest


  • public class MergeLatest
    extends java.lang.Object
    MergeLatest joins elements from N input streams into stream of lists of size N. i-th element in list is the latest emitted element from i-th input stream. MergeLatest emits list for each element emitted from some input stream, but only after each stream emitted at least one element

    '''Emits when''' element is available from some input and each input emits at least one element from stream start

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

    '''Cancels when''' downstream cancels

    • Constructor Summary

      Constructors 
      Constructor Description
      MergeLatest()  
    • Method Summary

      All Methods Static Methods Concrete Methods 
      Modifier and Type Method Description
      static <T> GraphStage<UniformFanInShape<T,​java.util.List<T>>> create​(int inputPorts)
      Create a new MergeLatest with the specified number of input ports.
      static <T> GraphStage<UniformFanInShape<T,​java.util.List<T>>> create​(int inputPorts, boolean eagerComplete)
      Create a new MergeLatest with the specified number of input ports.
      • Methods inherited from class java.lang.Object

        clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait
    • Constructor Detail

      • MergeLatest

        public MergeLatest()
    • Method Detail

      • create

        public static <T> GraphStage<UniformFanInShape<T,​java.util.List<T>>> create​(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.
      • create

        public static <T> GraphStage<UniformFanInShape<T,​java.util.List<T>>> create​(int inputPorts)
        Create a new MergeLatest with the specified number of input ports.

        Parameters:
        inputPorts - number of input ports