MergeHubDrainingControlImpl

java.lang.Object
- akka.stream.scaladsl.MergeHubDrainingControlImpl

All Implemented Interfaces:: MergeHub.DrainingControl

public final class MergeHubDrainingControlImpl
extends java.lang.Object
implements MergeHub.DrainingControl

- Constructor Summary
  
  Constructors
  Constructor Description
  
  MergeHubDrainingControlImpl(scala.Function0<scala.runtime.BoxedUnit> drainAction)
- Method Summary
  
  All Methods Instance Methods Concrete Methods
  Modifier and Type Method Description
  
  void drainAndComplete()
  Set the operation mode of the linked MergeHub to draining.
  - Methods inherited from class java.lang.Object
    clone, equals, finalize, getClass, hashCode, notify, notifyAll, toString, wait, wait, wait

- Constructor Detail
  - MergeHubDrainingControlImpl
```
public MergeHubDrainingControlImpl(scala.Function0<scala.runtime.BoxedUnit> drainAction)
```
- Method Detail
  - drainAndComplete
```
public void drainAndComplete()
```
    Description copied from interface: MergeHub.DrainingControl
    
    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.
    
    Specified by:
    
    drainAndComplete in interface MergeHub.DrainingControl