From 4b5d023d19137f1b1dae05592b2f93645e112a81 Mon Sep 17 00:00:00 2001
From: Thomas Nordquist <xxnerowingerxx@gmail.com>
Date: Mon, 18 Feb 2019 16:36:41 +0100
Subject: [PATCH] Fix disconnect unsubscribe

---
 backend/src/index.ts | 5 ++++-
 1 file changed, 4 insertions(+), 1 deletion(-)

diff --git a/backend/src/index.ts b/backend/src/index.ts
index 7c7ecd6..fd8dfdd 100644
--- 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) => {