Remove close listener before next startStreamProcess loop

This cause memory leak during fast publishing when leveldb store is used ```VM38 warning.js:27 (node:2090114) MaxListenersExceededWarning: Possible EventEmitter memory leak detected. 11 close listeners added to [MqttClient]. Use emitter.setMaxListeners() to increase limit```
mqttjs · Jan 30, 2020 · f9a8c28 · f9a8c28
1 parent 020ebfd
commit f9a8c28
Showing 1 changed file with 1 addition and 0 deletions.
diff --git a/lib/client.js b/lib/client.js
@@ -1448,6 +1448,7 @@ MqttClient.prototype._onConnect = function (packet) {
         that.removeListener('close', remove)
         that.emit('connect', packet)
       } else {
+        that.removeListener('close', remove)
         startStreamProcess()
       }
     })