Package akka.stream.javadsl
Interface MergeHub.DrainingControl
- 
- Enclosing class:
 - MergeHub
 
public static interface MergeHub.DrainingControlA 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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description voiddrainAndComplete()Set the operation mode of the linked MergeHub to draining. 
 -