From 0c10ef680ccc34bbe49948d414f36879d816e4e0 Mon Sep 17 00:00:00 2001
From: Daniel Lando <daniel.sorridi@gmail.com>
Date: Tue, 5 Dec 2023 16:40:15 +0100
Subject: [PATCH] fix: leaked `close` listener in `startStreamProcess` loop
 (#1759)

---
 src/lib/client.ts | 2 +-
 1 file changed, 1 insertion(+), 1 deletion(-)

diff --git a/src/lib/client.ts b/src/lib/client.ts
index 25320da2a..6f1e8bc9f 100644
--- a/src/lib/client.ts
+++ b/src/lib/client.ts
@@ -2260,9 +2260,9 @@ export default class MqttClient extends TypedEventEmitter<MqttClientEventCallbac
 						break
 					}
 				}
+				this.removeListener('close', remove)
 				if (allProcessed) {
 					clearStoreProcessing()
-					this.removeListener('close', remove)
 					this._invokeAllStoreProcessingQueue()
 					this.emit('connect', packet)
 				} else {