Package akka.stream.scaladsl
Interface MergeHub.DrainingControl
-
- All Known Implementing Classes:
MergeHubDrainingControlImpl
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.
-
-
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.
-