From b8b79d41e69e7bb023e7e1be99b112e2949be68c Mon Sep 17 00:00:00 2001
From: Sam Barker <sbarker@redhat.com>
Date: Fri, 9 Aug 2024 12:10:32 +1200
Subject: [PATCH] Drop exception handling test from AbstractInterceptorTest as
 its now better covered elsewhere.

---
 .../client/http/AbstractInterceptorTest.java  | 33 -------------------
 1 file changed, 33 deletions(-)

diff --git a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
index 18385888034..336729f3037 100644
--- a/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
+++ b/kubernetes-client-api/src/test/java/io/fabric8/kubernetes/client/http/AbstractInterceptorTest.java
@@ -22,7 +22,6 @@
 import org.junit.jupiter.api.DisplayName;
 import org.junit.jupiter.api.Test;
 
-import java.io.InputStream;
 import java.net.URI;
 import java.nio.ByteBuffer;
 import java.nio.charset.StandardCharsets;
@@ -32,7 +31,6 @@
 import java.util.List;
 import java.util.Set;
 import java.util.concurrent.CompletableFuture;
-import java.util.concurrent.CompletionException;
 import java.util.concurrent.ConcurrentHashMap;
 import java.util.concurrent.CountDownLatch;
 import java.util.concurrent.TimeUnit;
@@ -239,37 +237,6 @@ public void after(HttpRequest request, HttpResponse<?> response, Consumer<List<B
     }
   }
 
-  @Test
-  @DisplayName("afterConnectionFailure, completionExceptions are passed through")
-  public void afterConnectionFailureCompletionException() {
-    // Given
-    final CountDownLatch connectionFailureCallbackInvoked = new CountDownLatch(1);
-    final HttpClient.Builder builder = getHttpClientFactory().newBuilder()
-        .connectTimeout(1, TimeUnit.SECONDS)
-        .addOrReplaceInterceptor("test", new Interceptor() {
-          @Override
-          public void afterConnectionFailure(HttpRequest request, Throwable failure) {
-            connectionFailureCallbackInvoked.countDown();
-          }
-        });
-    // When
-    try (HttpClient client = builder.build()) {
-      final CompletableFuture<HttpResponse<String>> response = client.sendAsync(client.newHttpRequestBuilder()
-          .timeout(1, TimeUnit.SECONDS)
-          .uri(server.url("/intercepted-url"))
-          .method("POST", "application/json", new InputStream() {
-            @Override
-            public int read() {
-              throw new CompletionException("boom time", null); // gets propagated by jetty but gets wrapped by OkHttp
-            }
-          }, 1L).build(), String.class);
-
-      // Then
-      assertThat(response).failsWithin(FUTURE_COMPLETION_TIME);
-      assertThat(connectionFailureCallbackInvoked).extracting(CountDownLatch::getCount).isEqualTo(0L);
-    }
-  }
-
   @Test
   @DisplayName("afterFailure (HTTP), replaces the HttpResponse produced by HttpClient.consumeBytes")
   public void afterHttpFailureReplacesResponseInConsumeBytes() throws Exception {