Package org.apache.pekko.stream.javadsl

Interface MergeHub.DrainingControl

Enclosing class:
MergeHub
public static interface MergeHub.DrainingControl
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

  • Method Summary

    Modifier and Type
    Method
    Description
    void
    drainAndComplete()
    Set the operation mode of the linked MergeHub to draining.

  • Method Details

    • drainAndComplete

      void drainAndComplete()
      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.