public class Concat$
extends java.lang.Object
'''Emits when''' the current stream has an element available; if the current input completes, it tries the next one
'''Backpressures when''' downstream backpressures
'''Completes when''' all upstreams complete
'''Cancels when''' downstream cancels
Modifier and Type | Field and Description |
---|---|
static Concat$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
Concat$() |
Modifier and Type | Method and Description |
---|---|
<T> Graph<UniformFanInShape<T,T>,NotUsed> |
create()
Create a new anonymous
Concat stage with the specified input types. |
<T> Graph<UniformFanInShape<T,T>,NotUsed> |
create(java.lang.Class<T> clazz)
Create a new anonymous
Concat stage with the specified input types. |
<T> Graph<UniformFanInShape<T,T>,NotUsed> |
create(int inputCount)
Create a new anonymous
Concat stage with the specified input types. |
public static final Concat$ MODULE$
public <T> Graph<UniformFanInShape<T,T>,NotUsed> create()
Concat
stage with the specified input types.public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputCount)
Concat
stage with the specified input types.inputCount
- (undocumented)public <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz)
Concat
stage with the specified input types.clazz
- (undocumented)