summaryrefslogtreecommitdiff
diff options
context:
space:
mode:
authorLi Haoyi <haoyi.sg@gmail.com>2019-09-19 14:16:10 +0800
committerGitHub <noreply@github.com>2019-09-19 14:16:10 +0800
commite44b9de83a91f0e3e56a9234b6880312f585138b (patch)
tree08735429e7daf1ef36dc4b4e729c9cf6be123507
parent7012bb22c82131222c32c6d63e3c235538f4c260 (diff)
downloadcask-e44b9de83a91f0e3e56a9234b6880312f585138b.tar.gz
cask-e44b9de83a91f0e3e56a9234b6880312f585138b.tar.bz2
cask-e44b9de83a91f0e3e56a9234b6880312f585138b.zip
Update WebsocketClientImpl.scala
-rw-r--r--cask/util/src-jvm/cask/util/WebsocketClientImpl.scala10
1 files changed, 7 insertions, 3 deletions
diff --git a/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala b/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
index 5570356..0ac8c1d 100644
--- a/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
+++ b/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
@@ -4,8 +4,9 @@ import org.java_websocket.handshake.ServerHandshake
abstract class WebsocketClientImpl(url: String) extends WebsocketBase{
var websocket: Client = null
-
+ var closed = false
def connect(): Unit = {
+ closed = false
websocket = new Client()
websocket.connect()
}
@@ -32,8 +33,11 @@ abstract class WebsocketClientImpl(url: String) extends WebsocketBase{
WebsocketClientImpl.this.onOpen()
}
def onMessage(message: String) = WebsocketClientImpl.this.onMessage(message)
- def onClose(code: Int, reason: String, remote: Boolean) = WebsocketClientImpl.this.onClose(code, reason)
+ def onClose(code: Int, reason: String, remote: Boolean) = {
+ closed = true
+ WebsocketClientImpl.this.onClose(code, reason)
+ }
def onError(ex: Exception) = WebsocketClientImpl.this.onError(ex)
}
-} \ No newline at end of file
+}