Implement onFailure to complete the asyncResponse future.

fabric8io · Jul 26, 2024 · 2db6a92 · 2db6a92
1 parent eea7fc1
commit 2db6a92
Showing 1 changed file with 5 additions and 0 deletions.
diff --git a/...nt-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java b/...nt-jetty/src/main/java/io/fabric8/kubernetes/client/jetty/JettyAsyncResponseListener.java
@@ -79,6 +79,11 @@ public void onComplete(Result result) {
     }
   }
 
+  @Override
+  public void onFailure(Response response, Throwable failure) {
+    asyncResponse.completeExceptionally(failure);
+  }
+
   public CompletableFuture<HttpResponse<AsyncBody>> listen(Request request) {
     request.send(this);
     return asyncResponse.thenApply(HttpResponse.class::cast);