Merge pull request #151 from DanielHreben/master

Pass error to piped stream in centralDirectory
ZJONSSON · Sep 8, 2019 · cf47b10 · cf47b10
2 parents 5e57320 + 646dff0
commit cf47b10
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() {