public class MergePreferred$
extends java.lang.Object
'''Emits when''' one of the inputs has an element available, preferring a specified input if multiple have elements available
'''Backpressures when''' downstream backpressures
'''Completes when''' all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true)
'''Cancels when''' downstream cancels
Modifier and Type | Field and Description |
---|---|
static MergePreferred$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
MergePreferred$() |
Modifier and Type | Method and Description |
---|---|
<T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> |
create(java.lang.Class<T> clazz,
int secondaryPorts)
Create a new
MergePreferred stage with the specified output type. |
<T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> |
create(java.lang.Class<T> clazz,
int secondaryPorts,
boolean eagerComplete)
Create a new
MergePreferred stage with the specified output type. |
<T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> |
create(int secondaryPorts)
Create a new
MergePreferred stage with the specified output type. |
<T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> |
create(int secondaryPorts,
boolean eagerComplete)
Create a new
MergePreferred stage with the specified output type. |
public static final MergePreferred$ MODULE$
public <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(int secondaryPorts)
MergePreferred
stage with the specified output type.secondaryPorts
- (undocumented)public <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(java.lang.Class<T> clazz, int secondaryPorts)
MergePreferred
stage with the specified output type.clazz
- (undocumented)secondaryPorts
- (undocumented)public <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(int secondaryPorts, boolean eagerComplete)
MergePreferred
stage with the specified output type.
eagerComplete
- set to true in order to make this stage eagerly
finish as soon as one of its inputs completessecondaryPorts
- (undocumented)public <T> Graph<MergePreferred.MergePreferredShape<T>,NotUsed> create(java.lang.Class<T> clazz, int secondaryPorts, boolean eagerComplete)
MergePreferred
stage with the specified output type.
eagerComplete
- set to true in order to make this stage eagerly
finish as soon as one of its inputs completesclazz
- (undocumented)secondaryPorts
- (undocumented)