Fix "Possible EventEmitter memory leak detected. 1001 drain listeners…

… added to [Socket]" warning. #9822
Koenkk · Nov 29, 2021 · c2d9ffa · c2d9ffa
1 parent 82f5ddb
commit c2d9ffa
Show file tree

Hide file tree

Showing 2 changed files with 2 additions and 0 deletions.
diff --git a/lib/mqtt.ts b/lib/mqtt.ts
@@ -69,6 +69,7 @@ export default class MQTT {
 
         return new Promise((resolve, reject) => {
             this.client = mqtt.connect(mqttSettings.server, options);
+            this.client.setMaxListeners(0);
 
             const onConnect = this.onConnect;
             this.client.on('connect', async () => {

diff --git a/test/stub/mqtt.js b/test/stub/mqtt.js
@@ -6,6 +6,7 @@ const mock = {
     subscribe: jest.fn(),
     reconnecting: false,
     on: jest.fn(),
+    setMaxListeners: jest.fn(),
 };
 
 const mockConnect = jest.fn().mockReturnValue(mock);