Package org.apache.pekko.stream.javadsl

Class MergeLatest$

java.lang.Object

org.apache.pekko.stream.javadsl.MergeLatest$

public class MergeLatest$
extends 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 final MergeLatest$	MODULE$	Static reference to the singleton instance of this Scala object.

Constructor Summary

Constructors

Constructor	Description
MergeLatest$()

Method Summary

Modifier and Type	Method	Description
<T> GraphStage<UniformFanInShape<T,List<T>>>	create(int inputPorts)	Create a new MergeLatest with the specified number of input ports.
<T> GraphStage<UniformFanInShape<T,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

Field Details

MODULE$

public static final MergeLatest$ MODULE$

Static reference to the singleton instance of this Scala object.

Constructor Details

MergeLatest$

public MergeLatest$()

Method Details

create

public <T> GraphStage<UniformFanInShape<T,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 <T> GraphStage<UniformFanInShape<T,List<T>>> create(int inputPorts)

Create a new MergeLatest with the specified number of input ports.

Parameters:

inputPorts - number of input ports