public class KillSwitches
extends java.lang.Object
shared()
returns a SharedKillSwitch
which provides a Graph
of FlowShape
that can be
used in arbitrary number of graphs and materializations. The switch simultaneously
controls completion in all of those graphs.
- The factory
single()
returns a Graph
of FlowShape
that materializes to a UniqueKillSwitch
which is always unique
to that materialized Flow itself.
Creates a SharedKillSwitch
that can be used to externally control the completion of various streams.
Modifier and Type | Class and Description |
---|---|
static class |
KillSwitches.KillableGraphStageLogic |
static class |
KillSwitches.UniqueBidiKillSwitchStage$ |
static class |
KillSwitches.UniqueKillSwitchStage$ |
Constructor and Description |
---|
KillSwitches() |
Modifier and Type | Method and Description |
---|---|
static SharedKillSwitch |
shared(java.lang.String name)
Creates a new
SharedKillSwitch with the given name that can be used to control the completion of multiple
streams from the outside simultaneously. |
static <T> Graph<FlowShape<T,T>,UniqueKillSwitch> |
single()
|
static <T1,T2> Graph<BidiShape<T1,T1,T2,T2>,UniqueKillSwitch> |
singleBidi()
|
public static SharedKillSwitch shared(java.lang.String name)
SharedKillSwitch
with the given name that can be used to control the completion of multiple
streams from the outside simultaneously.
name
- (undocumented)SharedKillSwitch
public static <T> Graph<FlowShape<T,T>,UniqueKillSwitch> single()
Graph
of FlowShape
that materializes to an external switch that allows external completion
of that unique materialization. Different materializations result in different, independent switches.
For a Bidi version see KillSwitch#singleBidi
public static <T1,T2> Graph<BidiShape<T1,T1,T2,T2>,UniqueKillSwitch> singleBidi()
Graph
of FlowShape
that materializes to an external switch that allows external completion
of that unique materialization. Different materializations result in different, independent switches.
For a Flow version see KillSwitch#single