From 7fdc6611bea8d8643e4d4b9ef3fb9eaf1fec6a70 Mon Sep 17 00:00:00 2001 From: Blake B Date: Wed, 3 Nov 2021 04:09:58 -0400 Subject: [PATCH 1/2] Fix stream stalling on some files. --- index.js | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/index.js b/index.js index f369a29..e5f8077 100644 --- a/index.js +++ b/index.js @@ -38,7 +38,8 @@ export default class FileType extends Transform { _flush (cb) { if (this[kStream] != null) { - this[kStream].end(() => cb(null)) + this[kStream].end() + cb(null) } else { cb(null) } From 7a4439ec4a5cf5f66306b045d78112ba532acfb3 Mon Sep 17 00:00:00 2001 From: Blake B Date: Wed, 3 Nov 2021 04:18:48 -0400 Subject: [PATCH 2/2] Remove redundant callback. --- index.js | 4 +--- 1 file changed, 1 insertion(+), 3 deletions(-) diff --git a/index.js b/index.js index e5f8077..29c149b 100644 --- a/index.js +++ b/index.js @@ -39,9 +39,7 @@ export default class FileType extends Transform { _flush (cb) { if (this[kStream] != null) { this[kStream].end() - cb(null) - } else { - cb(null) } + cb(null) } }