raboof/pekko
1
0
Fork 0
Code Issues Pull requests Projects Releases 6 Packages Wiki Activity Actions 10

KillSwitch implementations should implement KillSwitch (#20459)

Browse source
This commit is contained in:
Derek Wickern 2016-05-06 05:37:06 -07:00 • committed by Konrad Malawski
parent fca95963e0
commit e8937f967a
1 changed files with 2 additions and 2 deletions
Download patch file Download diff file Expand all files Collapse all files

4
akka-stream/src/main/scala/akka/stream/KillSwitch.scala
View file

@ -159,7 +159,7 @@ trait KillSwitch {
* It is also possible to individually cancel, complete or fail upstream and downstream parts by calling the corresponding
* methods.
*/
final class UniqueKillSwitch private[stream] (private val promise: Promise[Done]) {
final class UniqueKillSwitch private[stream] (private val promise: Promise[Done]) extends KillSwitch {
/**
* After calling [[UniqueKillSwitch#shutdown()]] the running instance of the [[Graph]] of [[FlowShape]] that materialized to the
@ -200,7 +200,7 @@ final class UniqueKillSwitch private[stream] (private val promise: Promise[Done]
*
* This class is thread-safe, the instance can be passed safely among threads and its methods may be invoked concurrently.
*/
final class SharedKillSwitch private[stream] (val name: String) {
final class SharedKillSwitch private[stream] (val name: String) extends KillSwitch {
private[this] val shutdownPromise = Promise[Done]
private[this] val _flow: Graph[FlowShape[Any, Any], SharedKillSwitch] = new SharedKillSwitchFlow