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> 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 {