summaryrefslogtreecommitdiff
path: root/cask
diff options
context:
space:
mode:
authorLi Haoyi <haoyi.sg@gmail.com>2019-10-13 22:12:11 +0800
committerLi Haoyi <haoyi.sg@gmail.com>2019-10-13 22:15:36 +0800
commit12a91e2b6c78cd347996663f56eadb9616834823 (patch)
treed1efd0a8e5999f02c8f8429c4b8ed500ad4f2608 /cask
parent7b8f403a0d3f95a825a09a709bc17a694952683d (diff)
downloadcask-12a91e2b6c78cd347996663f56eadb9616834823.tar.gz
cask-12a91e2b6c78cd347996663f56eadb9616834823.tar.bz2
cask-12a91e2b6c78cd347996663f56eadb9616834823.zip
Fix StateMachine to properly inherit from BatchActor
Remove WsClient.close
Diffstat (limited to 'cask')
-rw-r--r--cask/util/src/cask/util/BatchActor.scala6
-rw-r--r--cask/util/src/cask/util/WsClient.scala2
2 files changed, 3 insertions, 5 deletions
diff --git a/cask/util/src/cask/util/BatchActor.scala b/cask/util/src/cask/util/BatchActor.scala
index fd4861e..4985fc3 100644
--- a/cask/util/src/cask/util/BatchActor.scala
+++ b/cask/util/src/cask/util/BatchActor.scala
@@ -36,9 +36,9 @@ abstract class BatchActor[T]()(implicit ec: ExecutionContext,
}
}
-abstract class StateMachine[T]()
- (implicit ec: ExecutionContext,
- log: Logger) {
+abstract class StateMachineActor[T]()
+ (implicit ec: ExecutionContext,
+ log: Logger) extends BatchActor[T](){
class State(val run: T => State)
protected[this] def initialState: State
protected[this] var state: State = initialState
diff --git a/cask/util/src/cask/util/WsClient.scala b/cask/util/src/cask/util/WsClient.scala
index 6ba039e..fbde444 100644
--- a/cask/util/src/cask/util/WsClient.scala
+++ b/cask/util/src/cask/util/WsClient.scala
@@ -13,8 +13,6 @@ class WsClient(impl: WebsocketBase)
case Ws.Close(_, _) => impl.close()
case Ws.ChannelClosed() => impl.close()
}
-
- def close(code: Int = 1005, reason: String = "") = this.send(Ws.Close(code, reason))
}
object WsClient{