Packages

  • package root
    Definition Classes
    root
  • package akka
    Definition Classes
    root
  • package stream
    Definition Classes
    akka
  • package javadsl
    Definition Classes
    stream
  • object MergeHub

    A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers.

    A MergeHub is a special streaming hub that is able to collect streamed elements from a dynamic set of producers. It consists of two parts, a Source and a Sink. The Source streams the element to a consumer from its merged inputs. Once the consumer has been materialized, the Source returns a materialized value which is the corresponding Sink. This Sink can then be materialized arbitrary many times, where each of the new materializations will feed its consumed elements to the original Source.

    Definition Classes
    javadsl
  • DrainingControl
t

akka.stream.javadsl.MergeHub

DrainingControl

sealed trait DrainingControl extends AnyRef

A DrainingControl object is created during the materialization of a MergeHub and allows to initiate the draining and eventual completion of the Hub from the outside.

Not for user extension

Annotations
@DoNotInherit()
Source
Hub.scala
Linear Supertypes
AnyRef, Any
Type Hierarchy
Ordering
  1. Alphabetic
  2. By Inheritance
Inherited
  1. DrainingControl
  2. AnyRef
  3. Any
Implicitly
  1. by any2stringadd
  2. by StringFormat
  3. by Ensuring
  4. by ArrowAssoc
  1. Hide All
  2. Show All
Visibility
  1. Public
  2. Protected

Abstract Value Members

  1. abstract def drainAndComplete(): Unit

    Set the operation mode of the linked MergeHub to draining.

    Set the operation mode of the linked MergeHub to draining. In this mode the Hub will cancel any new producer and will complete as soon as all the currently connected producers complete.