From e2990be264776d4d17e0fa982f74e1ad54624d0d Mon Sep 17 00:00:00 2001
From: Marcos Casagrande <marcoscvp90@gmail.com>
Date: Mon, 3 Oct 2022 06:18:59 +0200
Subject: fix(ext/cache): close resource on error (#16129)

---
 ext/cache/01_cache.js | 16 +++++++++-------
 1 file changed, 9 insertions(+), 7 deletions(-)

(limited to 'ext/cache')

diff --git a/ext/cache/01_cache.js b/ext/cache/01_cache.js
index c2843cedb..c22390a6d 100644
--- a/ext/cache/01_cache.js
+++ b/ext/cache/01_cache.js
@@ -141,15 +141,17 @@
         },
       );
       if (reader) {
-        while (true) {
-          const { value, done } = await reader.read();
-          if (done) {
-            await core.shutdown(rid);
-            core.close(rid);
-            break;
-          } else {
+        try {
+          while (true) {
+            const { value, done } = await reader.read();
+            if (done) {
+              break;
+            }
             await core.write(rid, value);
           }
+        } finally {
+          await core.shutdown(rid);
+          core.close(rid);
         }
       }
       // Step 12-19: TODO(@satyarohith): do the insertion in background.
-- 
cgit v1.2.3