diff --git a/httpclient-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java b/httpclient-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java index c2e88b2ca2d..3e41a791645 100644 --- a/httpclient-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java +++ b/httpclient-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java @@ -103,6 +103,11 @@ public void onContent(Response response, ByteBuffer content, Callback callback) } } + @Override + public void onFailure(Response response, Throwable failure) { + asyncResponse.completeExceptionally(failure); + } + /** * Implement to consume the content of the chunked response. *