fixup! http: align with stream.Writable

Author: ronag

lib/_http_outgoing.js

@@ -38,7 +38,8 @@ const {
   ObjectPrototypeHasOwnProperty,
   ObjectSetPrototypeOf,
   RegExpPrototypeTest,
-  StringPrototypeToLowerCase
+  StringPrototypeToLowerCase,
+  Symbol,
 } = primordials;
 
 const { getDefaultHighWaterMark } = require('internal/streams/state');
@@ -80,6 +81,8 @@ const { construct, destroy } = require('internal/streams/destroy');
 const HIGH_WATER_MARK = getDefaultHighWaterMark();
 const { CRLF, debug } = common;
 
+const kCorked = Symbol('kCorked');
+
 const nop = FunctionPrototype;
 
 const RE_CONN_CLOSE = /(?:^|\W)close(?:$|\W)/i;
@@ -120,6 +123,7 @@ function OutgoingMessage(opts) {
   this._trailer = '';
 
   this._headerSent = false;
+  this[kCorked] = 0;
 
   this.socket = null;
   this._header = null;
@@ -283,6 +287,8 @@ OutgoingMessage.prototype.cork = function() {
 
   if (this.socket) {
     this.socket.cork();
+  } else {
+    this[kCorked]++;
   }
 };
 
@@ -293,6 +299,8 @@ OutgoingMessage.prototype.uncork = function() {
 
   if (this.socket) {
     this.socket.uncork();
+  } else if (this[kCorked]) {
+    this[kCorked]--;
   }
 };
 
@@ -313,14 +321,14 @@ OutgoingMessage.prototype.setTimeout = function setTimeout(msecs, callback) {
 
 OutgoingMessage.prototype._construct = function(callback) {
   if (this.socket) {
-    for (let n = 0; n < this._writableState.corked; ++n) {
+    for (let n = 0; n < this[kCorked]; ++n) {
       this.socket.cork();
     }
     callback();
   } else {
     // TODO(ronag): What if never assigned socket?
     this.once('socket', function(socket) {
-      for (let n = 0; n < this._writableState.corked; ++n) {
+      for (let n = 0; n < this[kCorked]; ++n) {
         socket.cork();
       }
       callback();
@@ -772,7 +780,7 @@ function write_(msg, chunk, encoding, callback, fromEnd) {
 
   if (!fromEnd && !state.corked) {
     msg.cork();
-    process.nextTick(connectionCorkNT, msg);
+    process.nextTick(uncorkNT, msg);
   }
 
   let ret;
@@ -790,8 +798,8 @@ function write_(msg, chunk, encoding, callback, fromEnd) {
 }
 
 
-function connectionCorkNT(conn) {
-  conn.uncork();
+function uncorkNT(msg) {
+  msg.uncork();
 }