o

akka.stream.javadsl

MergePrioritized

object MergePrioritized

Merge several streams, taking elements as they arrive from input streams (picking from prioritized once when several have elements ready).

A MergePrioritized has one out port, one or more input port with their priorities.

Emits when one of the inputs has an element available, preferring a input based on its priority if multiple have elements available

Backpressures when downstream backpressures

Completes when all upstreams complete (eagerComplete=false) or one upstream completes (eagerComplete=true), default value is false

Cancels when downstream cancels

A Broadcast has one in port and 2 or more out ports.

Source
Graph.scala
Linear Supertypes
AnyRef, Any
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. MergePrioritized
  2. AnyRef
  3. Any
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. All

Value Members

  1. def create[T](clazz: Class[T], priorities: Array[Int], eagerComplete: Boolean): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new MergePrioritized operator with the specified output type.

    Create a new MergePrioritized 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

  2. def create[T](priorities: Array[Int], eagerComplete: Boolean): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new MergePrioritized operator with the specified output type.

    Create a new MergePrioritized 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

  3. def create[T](clazz: Class[T], priorities: Array[Int]): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new MergePrioritized operator with the specified output type.

  4. def create[T](priorities: Array[Int]): Graph[UniformFanInShape[T, T], NotUsed]

    Create a new MergePrioritized operator with the specified output type.