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 | Field and Description |
---|---|
static KillSwitches$ |
MODULE$
Static reference to the singleton instance of this Scala object.
|
Constructor and Description |
---|
KillSwitches$() |
Modifier and Type | Method and Description |
---|---|
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. |
<T> Graph<FlowShape<T,T>,UniqueKillSwitch> |
single()
|
<T1,T2> Graph<BidiShape<T1,T1,T2,T2>,UniqueKillSwitch> |
singleBidi()
|
public static final KillSwitches$ MODULE$
public 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 <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 <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