From d37926dd84bdbf727de670e725485aca98bd0ae5 Mon Sep 17 00:00:00 2001
From: Derrick Hammer <derrick@derrickhammer.com>
Date: Mon, 19 Sep 2022 16:51:02 -0400
Subject: [PATCH] *Catch error in stream and close the stream

---
 src/contentProviders/ipfsProvider.ts | 13 +++++++++----
 1 file changed, 9 insertions(+), 4 deletions(-)

diff --git a/src/contentProviders/ipfsProvider.ts b/src/contentProviders/ipfsProvider.ts
index 1af7923..cab84f8 100644
--- a/src/contentProviders/ipfsProvider.ts
+++ b/src/contentProviders/ipfsProvider.ts
@@ -230,10 +230,15 @@ export default class IpfsProvider extends BaseProvider {
     // @ts-ignore
     fetchMethod?.(hash, urlPath, (data: Buffer) => {
       streamWriter.write(data);
-    }).then(() => {
-      streamWriter.releaseLock();
-      return reqStream.close();
-    });
+    })
+      .then(() => {
+        streamWriter.releaseLock();
+        return reqStream.close();
+      })
+      .catch((e: any) => {
+        streamWriter.releaseLock();
+        reqStream.close();
+      });
 
     return {};
   }