diff --git a/lib/http.js b/lib/http.js index 687c335ef35..867d0261040 100644 --- a/lib/http.js +++ b/lib/http.js @@ -314,6 +314,10 @@ function IncomingMessage(socket) { // flag for backwards compatibility grossness. this._consuming = false; + + // flag for when we decide that this message cannot possibly be + // read by the user, so there's no point continuing to handle it. + this._dumped = false; } util.inherits(IncomingMessage, Stream.Readable);