Fix disconnect unsubscribe

2019-02-18 16:36:41 +01:00
parent e0708a5288
commit 4b5d023d19
1 changed files with 4 additions and 1 deletions
--- a/backend/src/index.ts
+++ b/backend/src/index.ts
@@ -20,7 +20,10 @@ export class ConnectionManager {

  public manageConnections() {
    backendEvents.subscribe(addMqttConnectionEvent, this.handleConnectionRequest)
-    backendEvents.subscribe(removeConnection, (connectionId: string) => this.removeConnection(connectionId))
+    backendEvents.subscribe(removeConnection, (connectionId: string) => {
+      backendEvents.unsubscribeAll(makePublishEvent(connectionId))
+      this.removeConnection(connectionId)
+    })
  }

  private handleConnectionRequest = (event: AddMqttConnection) => {