This repository was archived by the owner on May 14, 2024. It is now read-only.
File tree Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Expand file tree Collapse file tree 1 file changed +8
-4
lines changed Original file line number Diff line number Diff line change @@ -1114,6 +1114,12 @@ Client.prototype.connect = function connect() {
1114
1114
socket . once ( 'error' , bail ) ;
1115
1115
socket . once ( 'end' , bail ) ;
1116
1116
socket . once ( 'timeout' , bail ) ;
1117
+ socket . once ( 'cleanupSetupListeners' , function onCleanup ( ) {
1118
+ socket . removeListener ( 'error' , bail )
1119
+ . removeListener ( 'close' , bail )
1120
+ . removeListener ( 'end' , bail )
1121
+ . removeListener ( 'timeout' , bail ) ;
1122
+ } ) ;
1117
1123
1118
1124
self . _socket = socket ;
1119
1125
self . _tracker = tracker ;
@@ -1150,10 +1156,8 @@ Client.prototype.connect = function connect() {
1150
1156
1151
1157
// Wire up "official" event handlers after successful connect/setup
1152
1158
function postSetup ( ) {
1153
- socket . removeAllListeners ( 'error' )
1154
- . removeAllListeners ( 'close' )
1155
- . removeAllListeners ( 'end' )
1156
- . removeAllListeners ( 'timeout' ) ;
1159
+ // cleanup the listeners we attached in setup phrase.
1160
+ socket . emit ( 'cleanupSetupListeners' ) ;
1157
1161
1158
1162
// Work around lack of close event on tls.socket in node < 0.11
1159
1163
( ( socket . socket ) ? socket . socket : socket ) . once ( 'close' ,
You can’t perform that action at this time.
0 commit comments