This commit is contained in:
Koen Kanters
2021-11-30 20:20:46 +01:00
parent c90171d2cc
commit e7447cf1e3
2 changed files with 3 additions and 2 deletions
+2 -1
View File
@@ -69,7 +69,8 @@ export default class MQTT {
return new Promise((resolve, reject) => {
this.client = mqtt.connect(mqttSettings.server, options);
this.client.setMaxListeners(0);
// @ts-ignore https://github.com/Koenkk/zigbee2mqtt/issues/9822
this.client.stream.setMaxListeners(0);
const onConnect = this.onConnect;
this.client.on('connect', async () => {
+1 -1
View File
@@ -6,7 +6,7 @@ const mock = {
subscribe: jest.fn(),
reconnecting: false,
on: jest.fn(),
setMaxListeners: jest.fn(),
stream: {setMaxListeners: jest.fn()}
};
const mockConnect = jest.fn().mockReturnValue(mock);