fix: leaked close listener in startStreamProcess loop (#1759)

robertsLando · web-flow · commit 0c10ef680ccc · 2023-12-05T16:40:15.000+01:00
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 {

Original file line number	Diff line number	Diff line change
`@@ -2260,9 +2260,9 @@ export default class MqttClient extends TypedEventEmitter<MqttClientEventCallbac`
`2260`	`2260`	`break`
`2261`	`2261`	`}`
`2262`	`2262`	`}`
	`2263`	`+ this.removeListener('close', remove)`
`2263`	`2264`	`if (allProcessed) {`
`2264`	`2265`	`clearStoreProcessing()`
`2265`		`- this.removeListener('close', remove)`
`2266`	`2266`	`this._invokeAllStoreProcessingQueue()`
`2267`	`2267`	`this.emit('connect', packet)`
`2268`	`2268`	`} else {`