summaryrefslogtreecommitdiff
path: root/lib
diff options
context:
space:
mode:
Diffstat (limited to 'lib')
-rw-r--r--lib/_http_incoming.js13
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();
}
};