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
All Methods Instance Methods Abstract Methods Modifier and Type Method Description void
drainAndComplete()
Set the operation mode of the linked MergeHub to draining.
-