From a8607150e86c01ff1ade27171b27ea29af143871 Mon Sep 17 00:00:00 2001
From: Derrick Hammer <derrick@derrickhammer.com>
Date: Mon, 15 Aug 2022 13:30:35 -0400
Subject: [PATCH] *Close filter stream after processing buffer

---
 src/contentProviders/ipfsProvider.ts | 1 +
 1 file changed, 1 insertion(+)

diff --git a/src/contentProviders/ipfsProvider.ts b/src/contentProviders/ipfsProvider.ts
index 5135e71..42797b5 100644
--- a/src/contentProviders/ipfsProvider.ts
+++ b/src/contentProviders/ipfsProvider.ts
@@ -329,6 +329,7 @@ export default class IpfsProvider extends BaseProvider {
       .then(() => streamPromise)
       .then(() => {
         handleBuffer();
+        filterPromise.then(() => streamPromise).then(() => filter.close());
         resp = resp as StatFileResponse;
         if (resp.size <= MAX_CACHE_SIZE) {
           cacheBuffer = Uint8Array.from(