fix

nodejs · Mar 22, 2015 · 0011c68 · 0011c68
1 parent 1dd3af6
commit 0011c68
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 1 deletion.
diff --git a/lib/_stream_writable.js b/lib/_stream_writable.js
@@ -486,7 +486,7 @@ function finishMaybe(stream, state) {
   if (need) {
     if (state.pendingcb === 0) {
       prefinish(stream, state);
-      stream.flushed = true;
+      state.flushed = true;
       state._end(stream, function(err) {
         if (err)
           stream.emit('error', err);

diff --git a/lib/net.js b/lib/net.js
@@ -883,6 +883,7 @@ Socket.prototype.connect = function(options, cb) {
     this._readableState.endEmitted = false;
     this._writableState.ended = false;
     this._writableState.ending = false;
+    this._writableState.flushed = false;
     this._writableState.finished = false;
     this._writableState.errorEmitted = false;
     this.destroyed = false;