fix: remove close listener before next startStreamProcess loop

Ref #1038
mqttjs · Dec 5, 2023 · 9585927 · 9585927
1 parent 74882fb
commit 9585927
Showing 1 changed file with 1 addition and 1 deletion.
diff --git 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 {