Fix resource leaking on error in AsyncCachingExec

Author: Jouramie

httpclient5-cache/src/main/java/org/apache/hc/client5/http/impl/cache/AsyncCachingExec.java

@@ -135,8 +135,9 @@ private void triggerResponse(
         final SimpleBody body = cacheResponse.getBody();
         final byte[] content = body != null ? body.getBodyBytes() : null;
         final ContentType contentType = body != null ? body.getContentType() : null;
+        AsyncDataConsumer dataConsumer = null;
         try {
-            final AsyncDataConsumer dataConsumer = asyncExecCallback.handleResponse(
+            dataConsumer = asyncExecCallback.handleResponse(
                     cacheResponse,
                     content != null ? new BasicEntityDetails(content.length, contentType) : null);
             if (dataConsumer != null) {
@@ -148,6 +149,10 @@ private void triggerResponse(
             asyncExecCallback.completed();
         } catch (final HttpException | IOException ex) {
             asyncExecCallback.failed(ex);
+        } finally {
+            if (dataConsumer != null) {
+                dataConsumer.releaseResources();
+            }
         }
     }
 

httpclient5/src/main/java/org/apache/hc/client5/http/async/methods/InflatingZstdDataConsumer.java

@@ -130,7 +130,9 @@ public void streamEnd(final List<? extends Header> trailers) throws HttpExceptio
 
     @Override
     public void releaseResources() {
-        dctx.close();
+        if (closed.compareAndSet(false, true)) {
+            dctx.close();
+        }
         downstream.releaseResources();
     }
 }