From c49c1c5236255fb945c029d8cbcce316b4cffb9e 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  | 31 -------------------
 1 file changed, 31 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..7f87638f48b 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
@@ -239,37 +239,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 {