final class Concat[T] extends GraphStage[UniformFanInShape[T, T]]
Takes multiple streams and outputs one stream formed from the input streams by first emitting all of the elements from the first stream and then emitting all of the elements from the second stream, etc.
A Concat has one first port, one second port and one out port.
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
- Source
- Graph.scala
Linear Supertypes
Type Hierarchy
Ordering
- Alphabetic
- By Inheritance
Inherited
- Concat
- GraphStage
- GraphStageWithMaterializedValue
- Graph
- AnyRef
- Any
Implicitly
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
Visibility
- Public
- All
Type Members
-
type
Shape = UniformFanInShape[T, T]
Type-level accessor for the shape parameter of this graph.
Type-level accessor for the shape parameter of this graph.
- Definition Classes
- Graph
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
- def +(other: String): String
- def ->[B](y: B): (Concat[T], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addAttributes(attr: Attributes): Graph[UniformFanInShape[T, T], NotUsed]
- Definition Classes
- Graph
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
async: Graph[UniformFanInShape[T, T], NotUsed]
Put an asynchronous boundary around this
GraphPut an asynchronous boundary around this
Graph- Definition Classes
- Graph
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
def
createLogic(inheritedAttributes: Attributes): GraphStageLogic with OutHandler
- Definition Classes
- Concat → GraphStage
-
final
def
createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
- Definition Classes
- GraphStage → GraphStageWithMaterializedValue
- def ensuring(cond: (Concat[T]) ⇒ Boolean, msg: ⇒ Any): Concat[T]
- def ensuring(cond: (Concat[T]) ⇒ Boolean): Concat[T]
- def ensuring(cond: Boolean, msg: ⇒ Any): Concat[T]
- def ensuring(cond: Boolean): Concat[T]
-
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
finalize(): Unit
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @throws( classOf[java.lang.Throwable] )
- def formatted(fmtstr: String): String
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- val in: IndexedSeq[Inlet[T]]
-
def
initialAttributes: Attributes
- Definition Classes
- Concat → GraphStageWithMaterializedValue
- val inputPorts: Int
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
lazy val
module: Module
INTERNAL API.
INTERNAL API.
Every materializable element must be backed by a stream layout module
- Definition Classes
- GraphStageWithMaterializedValue → Graph
-
def
named(name: String): Graph[UniformFanInShape[T, T], NotUsed]
- Definition Classes
- Graph
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- val out: Outlet[T]
- val shape: UniformFanInShape[T, T]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- Concat → AnyRef → Any
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
withAttributes(attr: Attributes): Graph[UniformFanInShape[T, T], NotUsed]
- Definition Classes
- GraphStageWithMaterializedValue → Graph
- def →[B](y: B): (Concat[T], B)