Package akka.stream.javadsl
Class MergeLatest$
- java.lang.Object
-
- akka.stream.javadsl.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
-
-
Field Summary
Fields Modifier and Type Field Description static MergeLatest$
MODULE$
Static reference to the singleton instance of this Scala object.
-
Constructor Summary
Constructors Constructor Description MergeLatest$()
-
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description <T> GraphStage<UniformFanInShape<T,java.util.List<T>>>
create(int inputPorts)
Create a newMergeLatest
with the specified number of input ports.<T> GraphStage<UniformFanInShape<T,java.util.List<T>>>
create(int inputPorts, boolean eagerComplete)
Create a newMergeLatest
with the specified number of input ports.
-
-
-
Field Detail
-
MODULE$
public static final MergeLatest$ MODULE$
Static reference to the singleton instance of this Scala object.
-
-
Method Detail
-
create
public <T> GraphStage<UniformFanInShape<T,java.util.List<T>>> create(int inputPorts, boolean eagerComplete)
Create a newMergeLatest
with the specified number of input ports.- Parameters:
inputPorts
- number of input portseagerComplete
- if true, the merge latest will complete as soon as one of its inputs completes.
-
create
public <T> GraphStage<UniformFanInShape<T,java.util.List<T>>> create(int inputPorts)
Create a newMergeLatest
with the specified number of input ports.- Parameters:
inputPorts
- number of input ports
-
-