diff options
Diffstat (limited to 'lib')
-rw-r--r-- | lib/_http_incoming.js | 13 |
1 files changed, 5 insertions, 8 deletions
diff --git a/lib/_http_incoming.js b/lib/_http_incoming.js index 8949d4571a..cc93bfc9f1 100644 --- a/lib/_http_incoming.js +++ b/lib/_http_incoming.js @@ -23,14 +23,14 @@ var util = require('util'); var Stream = require('stream'); function readStart(socket) { - if (!socket || !socket._handle || !socket._handle.readStart) return; - socket._handle.readStart(); + if (socket) + socket.resume(); } exports.readStart = readStart; function readStop(socket) { - if (!socket || !socket._handle || !socket._handle.readStop) return; - socket._handle.readStop(); + if (socket) + socket.pause(); } exports.readStop = readStop; @@ -196,9 +196,6 @@ IncomingMessage.prototype._addHeaderLine = function(field, value, dest) { IncomingMessage.prototype._dump = function() { if (!this._dumped) { this._dumped = true; - if (this.socket.parser) this.socket.parser.incoming = null; - this.push(null); - readStart(this.socket); - this.read(); + this.resume(); } }; |