|
|
@ -367,6 +367,12 @@ Stream.prototype._onConnect = function () { |
|
|
|
this._connecting = false; |
|
|
|
this.resume(); |
|
|
|
this.readable = this.writable = true; |
|
|
|
|
|
|
|
if (this._writeWatcher.firstBucket) { |
|
|
|
// Flush this in case any writes are queued up while connecting.
|
|
|
|
this._onWritable(); |
|
|
|
} |
|
|
|
|
|
|
|
try { |
|
|
|
this.emit('connect'); |
|
|
|
} catch (e) { |
|
|
@ -374,12 +380,6 @@ Stream.prototype._onConnect = function () { |
|
|
|
return; |
|
|
|
} |
|
|
|
|
|
|
|
|
|
|
|
if (this._writeWatcher.firstBucket) { |
|
|
|
// Flush this in case any writes are queued up while connecting.
|
|
|
|
this._onWritable(); |
|
|
|
} |
|
|
|
|
|
|
|
} else if (errno != EINPROGRESS) { |
|
|
|
this.destroy(errnoException(errno, 'connect')); |
|
|
|
} |
|
|
|