fix: use pipeline to propagate errors across all piped streams (#288)

Co-authored-by: Ziggy Jonsson <ziggy.jonsson.nyc@gmail.com>

Author: oaleynik

lib/parse.js

@@ -7,6 +7,7 @@ var NoopStream = require('./NoopStream');
 var BufferStream = require('./BufferStream');
 var parseExtraField = require('./parseExtraField');
 var parseDateTime = require('./parseDateTime');
+var pipeline = Stream.pipeline;
 var parseBuffer = require('./parseBuffer');
 
 var endDirectorySignature = Buffer.alloc(4);
@@ -187,13 +188,18 @@ Parse.prototype._readFile = function () {
         }
 
         return new Promise(function(resolve, reject) {
-          self.stream(eof)
-            .pipe(inflater)
-            .on('error',function(err) { self.emit('error',err);})
-            .pipe(entry)
-            .on('finish', function() {
+          pipeline(
+            self.stream(eof),
+            inflater,
+            entry,
+            function (err) {
+              if (err) {
+                return reject(err);
+              }
+
               return fileSizeKnown ? resolve(fileSizeKnown) : self._processDataDescriptor(entry).then(resolve).catch(reject);
-            });
+            }
+          )
         });
       });
     });