1 files changed, 3 insertions, 1 deletions
diff --git a/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala b/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
index 0ac8c1d..2d65de6 100644
--- a/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
+++ b/cask/util/src-jvm/cask/util/WebsocketClientImpl.scala
@@ -26,7 +26,9 @@ abstract class WebsocketClientImpl(url: String) extends WebsocketBase{
   }
   def onClose(code: Int, reason: String): Unit
   def onError(ex: Exception): Unit
-  def close(): Unit = websocket.close()
+  def close(): Unit = {
+    if (!closed) websocket.close()
+  }
   def isClosed() = websocket.isClosed()
   class Client() extends WebSocketClient(new java.net.URI(url)){
     def onOpen(handshakedata: ServerHandshake) = {