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
Constructor and Description |
---|
Concat() |
Modifier and Type | Method and Description |
---|---|
static <T> Graph<UniformFanInShape<T,T>,NotUsed> |
create()
Create a new anonymous
Concat stage with the specified input types. |
static <T> Graph<UniformFanInShape<T,T>,NotUsed> |
create(java.lang.Class<T> clazz)
Create a new anonymous
Concat stage with the specified input types. |
static <T> Graph<UniformFanInShape<T,T>,NotUsed> |
create(int inputCount)
Create a new anonymous
Concat stage with the specified input types. |
public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create()
Concat
stage with the specified input types.public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(int inputCount)
Concat
stage with the specified input types.inputCount
- (undocumented)public static <T> Graph<UniformFanInShape<T,T>,NotUsed> create(java.lang.Class<T> clazz)
Concat
stage with the specified input types.clazz
- (undocumented)