adding missing flushes

fabric8io · Jan 30, 2022 · fa8e100 · fa8e100
1 parent 4ed2579
commit fa8e100
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/...client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java b/...client/src/main/java/io/fabric8/kubernetes/client/dsl/internal/ExecWebSocketListener.java
@@ -242,11 +242,13 @@ public void onMessage(WebSocket webSocket, ByteBuffer bytes) {
                     case 2:
                         if (err != null) {
                           Channels.newChannel(err).write(byteString);
+                          err.flush();
                         }
                         break;
                     case 3:
                         if (errChannel != null) {
                           Channels.newChannel(errChannel).write(byteString);
+                          errChannel.flush();
                         }
                         break;
                     default: