Reduce WebSocket flush delay from 100ms to 1ms

Copilot · brendandburns · Copilot · commit 2d7b94c16c38 · 2025-12-10T19:07:20.000Z
Co-authored-by: brendandburns &lt;5751682+brendandburns@users.noreply.github.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
@@ -272,11 +272,11 @@ public void flush() throws IOException {
       int i = 0;
       while (WebSocketStreamHandler.this.socket.queueSize() > 0) {
         try {
-          Thread.sleep(100);
+          Thread.sleep(1);
         } catch (InterruptedException ex) {
         }
         // Wait a maximum of 10 seconds.
-        if (i++ > 100) {
+        if (i++ > 10000) {
           throw new IOException("Timed out waiting for web-socket to flush.");
         }
       }

Original file line number	Diff line number	Diff line change
`@@ -272,11 +272,11 @@ public void flush() throws IOException {`
`272`	`272`	`int i = 0;`
`273`	`273`	`while (WebSocketStreamHandler.this.socket.queueSize() > 0) {`
`274`	`274`	`try {`
`275`		`- Thread.sleep(100);`
	`275`	`+ Thread.sleep(1);`
`276`	`276`	`} catch (InterruptedException ex) {`
`277`	`277`	`}`
`278`	`278`	`// Wait a maximum of 10 seconds.`
`279`		`- if (i++ > 100) {`
	`279`	`+ if (i++ > 10000) {`
`280`	`280`	`throw new IOException("Timed out waiting for web-socket to flush.");`
`281`	`281`	`}`
`282`	`282`	`}`