Merge pull request #257 from PawelSuwinski/UnhandledPromiseRejectionWarning

Unhandled promise rejection warning

Author: richardgirges

lib/processMultipart.js

@@ -57,6 +57,15 @@ module.exports = (options, req, res, next) => {
     } = options.useTempFiles
       ? tempFileHandler(options, field, filename) // Upload into temporary file.
       : memHandler(options, field, filename);     // Upload into RAM.
+
+    const writePromise = options.useTempFiles
+      ? getWritePromise().catch(err => {
+        req.unpipe(busboy);
+        req.resume();
+        cleanup();
+        next(err);
+      }) : getWritePromise();
+
     // Define upload timer.
     const uploadTimer = new UploadTimer(options.uploadTimeout, () => {
       file.removeAllListeners('data');
@@ -114,7 +123,7 @@ module.exports = (options, req, res, next) => {
       if (!req[waitFlushProperty]) {
         req[waitFlushProperty] = [];
       }
-      req[waitFlushProperty].push(getWritePromise());
+      req[waitFlushProperty].push(writePromise);
     });
 
     file.on('error', (err) => {
@@ -142,10 +151,6 @@ module.exports = (options, req, res, next) => {
       .then(() => {
         delete req[waitFlushProperty];
         next();
-      }).catch(err => {
-        delete req[waitFlushProperty];
-        debugLog(options, `Error while waiting files flush: ${err}`);
-        next(err);
       });
   });