final class Balance[T] extends GraphStage[UniformFanOutShape[T, T]]
Fan-out the stream to several streams. Each upstream element is emitted to the first available downstream consumer. It will not shut down until the subscriptions for at least two downstream subscribers have been established.
A Balance
has one in
port and 2 or more out
ports.
Emits when any of the outputs stops backpressuring; emits the element to the first available output
Backpressures when all of the outputs backpressure
Completes when upstream completes
Cancels when all downstreams cancel
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- Balance
- GraphStage
- GraphStageWithMaterializedValue
- Graph
- AnyRef
- Any
- by any2stringadd
- by StringFormat
- by Ensuring
- by ArrowAssoc
- Hide All
- Show All
- Public
- All
Type Members
-
type
Shape = UniformFanOutShape[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): (Balance[T], B)
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
def
addAttributes(attr: Attributes): Graph[UniformFanOutShape[T, T], NotUsed]
- Definition Classes
- Graph
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
async: Graph[UniformFanOutShape[T, T], NotUsed]
Put an asynchronous boundary around this
Graph
Put 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
- Definition Classes
- Balance → GraphStage
-
final
def
createLogicAndMaterializedValue(inheritedAttributes: Attributes): (GraphStageLogic, NotUsed)
- Definition Classes
- GraphStage → GraphStageWithMaterializedValue
- def ensuring(cond: (Balance[T]) ⇒ Boolean, msg: ⇒ Any): Balance[T]
- def ensuring(cond: (Balance[T]) ⇒ Boolean): Balance[T]
- def ensuring(cond: Boolean, msg: ⇒ Any): Balance[T]
- def ensuring(cond: Boolean): Balance[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: Inlet[T]
-
def
initialAttributes: Attributes
- Definition Classes
- Balance → GraphStageWithMaterializedValue
-
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[UniformFanOutShape[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: IndexedSeq[Outlet[T]]
- val outputPorts: Int
- val shape: UniformFanOutShape[T, T]
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- Balance → 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( ... )
- val waitForAllDownstreams: Boolean
-
final
def
withAttributes(attr: Attributes): Graph[UniformFanOutShape[T, T], NotUsed]
- Definition Classes
- GraphStageWithMaterializedValue → Graph
- def →[B](y: B): (Balance[T], B)