*Close filter stream after processing buffer

This commit is contained in:
Derrick Hammer 2022-08-15 13:30:35 -04:00
parent a105c9471d
commit a8607150e8
Signed by: pcfreak30
GPG Key ID: C997C339BE476FF2
1 changed files with 1 additions and 0 deletions

View File

@ -329,6 +329,7 @@ export default class IpfsProvider extends BaseProvider {
.then(() => streamPromise) .then(() => streamPromise)
.then(() => { .then(() => {
handleBuffer(); handleBuffer();
filterPromise.then(() => streamPromise).then(() => filter.close());
resp = resp as StatFileResponse; resp = resp as StatFileResponse;
if (resp.size <= MAX_CACHE_SIZE) { if (resp.size <= MAX_CACHE_SIZE) {
cacheBuffer = Uint8Array.from( cacheBuffer = Uint8Array.from(