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 {}; }