Disposed subscriptions on removal. Fixes #5

PeteGoo · Mar 2, 2013 · 24d0a54 · 24d0a54
1 parent ed7621c
commit 24d0a54
Showing 1 changed file with 3 additions and 0 deletions.
diff --git a/src/Pushqa.Server/SignalR/QueryablePushService.cs b/src/Pushqa.Server/SignalR/QueryablePushService.cs
@@ -124,6 +124,9 @@ public class QueryablePushService<T> : PersistentConnection where T : new() {
         protected override Task OnDisconnected(IRequest request, string connectionId) {
             IDisposable success;
             subscriptions.TryRemove(connectionId, out success);
+            if (success != null) {
+                success.Dispose();
+            }
             logger.Log(Logger.LogLevel.Debug, string.Format("Client {0} has disconnected from server. Number of remaining connected clients {1}", connectionId, subscriptions.Count));
             return base.OnDisconnected(request, connectionId);
         }