From 95859279424b5fe27d0790cb267fdc640c25dd08 Mon Sep 17 00:00:00 2001
From: Daniel Lando <daniel.sorridi@gmail.com>
Date: Tue, 5 Dec 2023 16:38:03 +0100
Subject: [PATCH] fix: remove close listener before next startStreamProcess
 loop

Ref #1038
---
 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 {