diff --git a/lib/_http_outgoing.js b/lib/_http_outgoing.js index 283a5ab824..6650c06c33 100644 --- a/lib/_http_outgoing.js +++ b/lib/_http_outgoing.js @@ -161,10 +161,12 @@ OutgoingMessage.prototype._writeRaw = function(data, encoding, callback) { var output = this.output; var outputEncodings = this.outputEncodings; var outputCallbacks = this.outputCallbacks; + connection.cork(); for (var i = 0; i < outputLength; i++) { connection.write(output[i], outputEncodings[i], outputCallbacks[i]); } + connection.uncork(); this.output = []; this.outputEncodings = []; @@ -651,10 +653,12 @@ OutgoingMessage.prototype._flush = function() { var output = this.output; var outputEncodings = this.outputEncodings; var outputCallbacks = this.outputCallbacks; + socket.cork(); for (var i = 0; i < outputLength; i++) { ret = socket.write(output[i], outputEncodings[i], outputCallbacks[i]); } + socket.uncork(); this.output = []; this.outputEncodings = [];