diff options
| -rw-r--r-- | lib/_http_incoming.js | 13 | ||||
| -rw-r--r-- | test/simple/test-http-byteswritten.js | 5 |
2 files changed, 6 insertions, 12 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(); } }; diff --git a/test/simple/test-http-byteswritten.js b/test/simple/test-http-byteswritten.js index 92bb2729c5..dedc2399c2 100644 --- a/test/simple/test-http-byteswritten.js +++ b/test/simple/test-http-byteswritten.js @@ -58,9 +58,6 @@ var httpServer = http.createServer(function(req, res) { }); httpServer.listen(common.PORT, function() { - // XXX(isaacs): This should not be necessary. - http.get({ port: common.PORT }, function(res) { - res.resume(); - }); + http.get({ port: common.PORT }); }); |