object MergePreferred
Merge several streams, taking elements as they arrive from input streams (picking from preferred when several have elements ready).
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
- Source
- Graph.scala
- Alphabetic
- By Inheritance
- MergePreferred
- AnyRef
- Any
- Hide All
- Show All
- Public
- All
Value Members
-
final
def
!=(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
##(): Int
- Definition Classes
- AnyRef → Any
-
final
def
==(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
asInstanceOf[T0]: T0
- Definition Classes
- Any
-
def
clone(): AnyRef
- Attributes
- protected[java.lang]
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate() @throws( ... )
-
def
create[T](clazz: Class[T], secondaryPorts: Int, eagerComplete: Boolean): Graph[MergePreferredShape[T], NotUsed]
Create a new
MergePreferred
operator with the specified output type.Create a new
MergePreferred
operator with the specified output type.- eagerComplete
set to true in order to make this operator eagerly finish as soon as one of its inputs completes
-
def
create[T](secondaryPorts: Int, eagerComplete: Boolean): Graph[MergePreferredShape[T], NotUsed]
Create a new
MergePreferred
operator with the specified output type.Create a new
MergePreferred
operator with the specified output type.- eagerComplete
set to true in order to make this operator eagerly finish as soon as one of its inputs completes
-
def
create[T](clazz: Class[T], secondaryPorts: Int): Graph[MergePreferredShape[T], NotUsed]
Create a new
MergePreferred
operator with the specified output type. -
def
create[T](secondaryPorts: Int): Graph[MergePreferredShape[T], NotUsed]
Create a new
MergePreferred
operator with the specified output type. -
final
def
eq(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
def
equals(arg0: Any): Boolean
- Definition Classes
- AnyRef → Any
-
final
def
getClass(): Class[_]
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
def
hashCode(): Int
- Definition Classes
- AnyRef → Any
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
isInstanceOf[T0]: Boolean
- Definition Classes
- Any
-
final
def
ne(arg0: AnyRef): Boolean
- Definition Classes
- AnyRef
-
final
def
notify(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
notifyAll(): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @HotSpotIntrinsicCandidate()
-
final
def
synchronized[T0](arg0: ⇒ T0): T0
- Definition Classes
- AnyRef
-
def
toString(): String
- Definition Classes
- AnyRef → Any
-
final
def
wait(arg0: Long, arg1: Int): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )
-
final
def
wait(arg0: Long): Unit
- Definition Classes
- AnyRef
- Annotations
- @native() @throws( ... )
-
final
def
wait(): Unit
- Definition Classes
- AnyRef
- Annotations
- @throws( ... )