fix: prevent runtime issues when running with Vert.x HTTP client in n…

…ative mode

Signed-off-by: Marc Nuri <[email protected]>

CHANGELOG.md

@@ -18,6 +18,7 @@
 * fix #5036: Better websocket error handling for protocol / client enforced errors, also update frame/message limits
 * Fix #5044: disable Vert.x instance file caching
 * Fix #5059: Vert.x InputStreamReader uses an empty Buffer sentinel to avoid NPE
+* Fix #5085: Vert.x HTTP Client InputStreamReadStream works in Native mode
 
 #### Improvements
 * Fix #4434: Update CronJobIT to use `batch/v1` CronJob instead

httpclient-vertx/src/main/java/io/fabric8/kubernetes/client/vertx/InputStreamReadStream.java

@@ -30,10 +30,10 @@
 
 class InputStreamReadStream implements ReadStream<Buffer> {
 
-  private static final Buffer END_SENTINEL = Buffer.buffer();
   private static final int CHUNK_SIZE = 2048;
   private static final int MAX_DEPTH = 8;
 
+  private final Buffer endSentinel;
   private final VertxHttpRequest vertxHttpRequest;
   private final InputStream is;
   private final HttpClientRequest request;
@@ -46,6 +46,7 @@ public InputStreamReadStream(VertxHttpRequest vertxHttpRequest, InputStream is,
     this.vertxHttpRequest = vertxHttpRequest;
     this.is = is;
     this.request = request;
+    endSentinel = Buffer.buffer();
   }
 
   @Override
@@ -72,7 +73,7 @@ public ReadStream<Buffer> handler(Handler<Buffer> handler) {
     }
     if (handler != null) {
       inboundBuffer.handler(buff -> {
-        if (buff == END_SENTINEL) {
+        if (buff == endSentinel) {
           if (endHandler != null) {
             endHandler.handle(null);
           }
@@ -133,7 +134,7 @@ private void readChunk2() {
             // Full
           }
         } else {
-          inboundBuffer.write(END_SENTINEL);
+          inboundBuffer.write(endSentinel);
         }
       } else {
         if (exceptionHandler != null) {