Package akka.stream.javadsl
Class MergeLatest
- java.lang.Object
-
- akka.stream.javadsl.MergeLatest
-
public class MergeLatest extends java.lang.Object
Create a newMergeLatest
with the specified number of input ports.param: inputPorts number of input ports param: eagerComplete if true, the merge latest will complete as soon as one of its inputs completes.
-
-
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 newMergeLatest
with the specified number of input ports.static <T> GraphStage<UniformFanInShape<T,java.util.List<T>>>
create(int inputPorts, boolean eagerComplete)
-
-
-
Method Detail
-
create
public static <T> GraphStage<UniformFanInShape<T,java.util.List<T>>> create(int inputPorts, boolean eagerComplete)
-
create
public static <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- Returns:
- (undocumented)
-
-