test: drain HttpResponse in tests (5852)

Drain `HttpResponse` in tests

Motivation:

In Armeria CI, we saw Netty leak reports from kubernetes-client CI tests.
After investigating, I found out that some of the tests did not
consume `HttpResponse`. As a result, some `ByteBuf`s were not
subscribed to and remained in the Publisher's internal buffer.

Modifications:

- Fixed to call `AsyncBody.consume()` where it was not called before.

Result:

No more leaks in CI builds.

Author: manusa

kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java

@@ -225,10 +225,12 @@ public CompletableFuture<Boolean> afterFailure(BasicBuilder builder, HttpRespons
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/not-found")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(interceptedResponses)
@@ -279,10 +281,12 @@ public void after(HttpRequest request, HttpResponse<?> response, Consumer<List<B
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/success")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(responseFuture)
@@ -306,10 +310,12 @@ public void after(HttpRequest request, HttpResponse<?> response, Consumer<List<B
         });
     // When
     try (HttpClient client = builder.build()) {
-      client.consumeBytes(
+      final HttpResponse<AsyncBody> asyncR = client.consumeBytes(
           client.newHttpRequestBuilder().uri(server.url("/client-error")).build(),
           (s, ab) -> ab.consume())
           .get(10, TimeUnit.SECONDS);
+      asyncR.body().consume();
+      asyncR.body().done().get(10L, TimeUnit.SECONDS);
     }
     // Then
     assertThat(responseFuture)

kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractSimultaneousConnectionsTest.java

@@ -118,7 +118,11 @@ public void http1Connections() throws Exception {
       assertThat(asyncResponses)
           .hasSize(MAX_HTTP_1_CONNECTIONS)
           .extracting(CompletableFuture::join)
-          .extracting(HttpResponse::code).containsOnly(204);
+          .extracting(response -> {
+            response.body().consume();
+            return response.code();
+          })
+          .containsOnly(204);
     }
   }