org.apache.pekko.stream.javadsl.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
Attributes
-
Source
-
Graph.scala
-
Graph
-
-
Supertypes
-
class Object
trait Matchable
class Any
-
Self type
-
Members list
Create a new MergePreferred operator with the specified output type.
Create a new MergePreferred operator with the specified output type.
Attributes
-
Source
-
Graph.scala
Create a new MergePreferred operator with the specified output type.
Create a new MergePreferred operator with the specified output type.
Attributes
-
Source
-
Graph.scala
Create a new MergePreferred operator with the specified output type.
Create a new MergePreferred operator with the specified output type.
Value parameters
-
eagerComplete
-
set to true in order to make this operator eagerly finish as soon as one of its inputs completes
Attributes
-
Source
-
Graph.scala
Create a new MergePreferred operator with the specified output type.
Create a new MergePreferred operator with the specified output type.
Value parameters
-
eagerComplete
-
set to true in order to make this operator eagerly finish as soon as one of its inputs completes
Attributes
-
Source
-
Graph.scala