Merge pull request #2574 from stevenschlansker/websocket-close

WebSockets: handle onClosing

Author: k8s-ci-robot

util/src/main/java/io/kubernetes/client/util/WebSockets.java

@@ -145,6 +145,12 @@ public void onMessage(WebSocket webSocket, ByteString bytes) {
     @Override
     public void onClosing(WebSocket webSocket, int code, String reason) {
       super.onClosing(webSocket, code, reason);
+      if (code == 1000) {
+        webSocket.close(1000, "Normal close");
+      } else {
+        log.warn("Unexpected WebSocket ({}) closure: {} {}", webSocket, code, reason);
+        webSocket.close(1002, "Abnormal close");
+      }
     }
 
     @Override