diff options
author | Li Haoyi <haoyi.sg@gmail.com> | 2019-09-19 14:16:10 +0800 |
---|---|---|
committer | GitHub <noreply@github.com> | 2019-09-19 14:16:10 +0800 |
commit | e44b9de83a91f0e3e56a9234b6880312f585138b (patch) | |
tree | 08735429e7daf1ef36dc4b4e729c9cf6be123507 /cask/util | |
parent | 7012bb22c82131222c32c6d63e3c235538f4c260 (diff) | |
download | cask-e44b9de83a91f0e3e56a9234b6880312f585138b.tar.gz cask-e44b9de83a91f0e3e56a9234b6880312f585138b.tar.bz2 cask-e44b9de83a91f0e3e56a9234b6880312f585138b.zip |
Update WebsocketClientImpl.scala
Diffstat (limited to 'cask/util')
-rw-r--r-- | cask/util/src-jvm/cask/util/WebsocketClientImpl.scala | 10 |
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 +} |