Dummy parser is a stream

Author: GrosSacASac

example/multipartParser.js

@@ -24,4 +24,4 @@ multipartParser.on('error', (error) => {
 multipartParser.initWithBoundary(boundary.substring(2)); // todo make better error message when it is forgotten
 const shouldWait = !multipartParser.write(buffer);
 multipartParser.end();
-// multipartParser.destroy();
+// multipartParser.destroy();

lib/dummy_parser.js

@@ -0,0 +1,18 @@
+const { Transform } = require('stream');
+
+
+class DummyParser extends Transform {
+  constructor(incomingForm) {
+    super();
+    this.incomingForm = incomingForm;
+  }
+  
+  _flush(callback) {
+    this.incomingForm.ended = true;
+    this.incomingForm._maybeEnd();
+    callback();
+  }
+}
+
+
+exports.DummyParser = DummyParser;

lib/incoming_form.js

@@ -6,6 +6,7 @@ var util = require('util'),
     path = require('path'),
     File = require('./file'),
     defaultOptions = require('./default_options').defaultOptions,
+    DummyParser = require('./dummy_parser').DummyParser,
     MultipartParser = require('./multipart_parser').MultipartParser,
     QuerystringParser = require('./querystring_parser').QuerystringParser,
     OctetParser       = require('./octet_parser').OctetParser,
@@ -145,6 +146,7 @@ IncomingForm.prototype.parse = function(req, cb) {
       this._parser.end();
     });
 
+  console.log(this._parser)
   this._parser.once('error', (error) => {
     this._error(error);
   });
@@ -252,19 +254,10 @@ IncomingForm.prototype.handlePart = function(part) {
   });
 };
 
-function dummyParser(incomingForm) {
-  return {
-    end: function () {
-      incomingForm.ended = true;
-      incomingForm._maybeEnd();
-      return null;
-    }
-  };
-}
 
 IncomingForm.prototype._parseContentType = function() {
   if (this.bytesExpected === 0) {
-    this._parser = dummyParser(this);
+    this._parser = new DummyParser(this);
     return;
   }