Package akka.stream
Class KillSwitches$
- java.lang.Object
 - 
- akka.stream.KillSwitches$
 
 
- 
public class KillSwitches$ extends java.lang.ObjectCreates shared or single kill switches which can be used to control completion of graphs from the outside. - The factoryshared()returns aSharedKillSwitchwhich provides aGraphofFlowShapethat can be used in arbitrary number of graphs and materializations. The switch simultaneously controls completion in all of those graphs. - The factorysingle()returns aGraphofFlowShapethat materializes to aUniqueKillSwitchwhich is always unique to that materialized Flow itself.Creates a
SharedKillSwitchthat can be used to externally control the completion of various streams. 
- 
- 
Field Summary
Fields Modifier and Type Field Description static KillSwitches$MODULE$Static reference to the singleton instance of this Scala object. 
- 
Constructor Summary
Constructors Constructor Description KillSwitches$() 
- 
Method Summary
All Methods Instance Methods Concrete Methods Modifier and Type Method Description SharedKillSwitchshared(java.lang.String name)Creates a newSharedKillSwitchwith the given name that can be used to control the completion of multiple streams from the outside simultaneously.<T> Graph<FlowShape<T,T>,UniqueKillSwitch>single()<T1,T2>
Graph<BidiShape<T1,T1,T2,T2>,UniqueKillSwitch>singleBidi() 
 - 
 
- 
- 
Field Detail
- 
MODULE$
public static final KillSwitches$ MODULE$
Static reference to the singleton instance of this Scala object. 
 - 
 
- 
Method Detail
- 
shared
public SharedKillSwitch shared(java.lang.String name)
Creates a newSharedKillSwitchwith the given name that can be used to control the completion of multiple streams from the outside simultaneously.- See Also:
 SharedKillSwitch
 
- 
single
public <T> Graph<FlowShape<T,T>,UniqueKillSwitch> single()
 
- 
singleBidi
public <T1,T2> Graph<BidiShape<T1,T1,T2,T2>,UniqueKillSwitch> singleBidi()
 
 - 
 
 -