fix: format

dani8art · dani8art · commit 87fea18eedef · 2022-09-22T16:40:23.000+02:00
Signed-off-by: Daniel Arteaga Barba &lt;darteaga@vmware.com&gt;
diff --git a/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java b/util/src/main/java/io/kubernetes/client/util/WebSocketStreamHandler.java
@@ -210,11 +210,11 @@ private synchronized OutputStream getSocketInputOutputStream(int stream) {
 
   private class WebSocketOutputStream extends OutputStream {
 
-    private static final long WEB_SOCKET_MAX_QUEUE_SIZE = 16L * 1024 * 1024;
+    private static final long MAX_QUEUE_SIZE = 16L * 1024 * 1024;
 
-    private static final int WEB_SOCKET_MAX_QUEUE_SIZE_MAX_ATTEMPTS = 15;
+    private static final int MAX_QUEUE_SIZE_MAX_ATTEMPTS = 15;
 
-    private static final int WEB_SOCKET_MAX_QUEUE_SIZE_WAIT_MILLISECONDS = 1000;
+    private static final int MAX_QUEUE_SIZE_WAIT_MILLISECONDS = 1000;
 
     private final byte stream;
 
@@ -277,11 +277,11 @@ public void write(byte[] b, int offset, int length) throws IOException {
         ByteString byteString = ByteString.of(buffer);
 
         int attempts = 0;
-        while (WebSocketStreamHandler.this.socket.queueSize() + byteString.size() > WEB_SOCKET_MAX_QUEUE_SIZE
-            && attempts < WEB_SOCKET_MAX_QUEUE_SIZE_MAX_ATTEMPTS) {
+        while (WebSocketStreamHandler.this.socket.queueSize() + byteString.size() > MAX_QUEUE_SIZE
+            && attempts < MAX_QUEUE_SIZE_MAX_ATTEMPTS) {
           try {
-            Thread.sleep(WEB_SOCKET_MAX_QUEUE_SIZE_WAIT_MILLISECONDS);
-            attempts ++;
+            Thread.sleep(MAX_QUEUE_SIZE_WAIT_MILLISECONDS);
+            attempts++;
           } catch (InterruptedException e) {
             throw new IOException("Error waiting web socket queue", e);
           }
