Pass error to piped stream in centralDirectory

ZJONSSON · Sep 7, 2019 · 646dff0 · 646dff0
1 parent 5e57320
commit 646dff0
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/lib/Open/directory.js b/lib/Open/directory.js
@@ -93,7 +93,11 @@ module.exports = function centralDirectory(source, options) {
   return source.size()
     .then(function(size) {
       sourceSize = size;
-      source.stream(Math.max(0,size-tailSize)).pipe(endDir);
+
+      source.stream(Math.max(0,size-tailSize))
+        .on('error', function (error) { endDir.emit('error', error) })
+        .pipe(endDir);
+
       return endDir.pull(signature);
     })
     .then(function() {