From 4f42b323859ef56c17b5bb39585326951bbd7640 Mon Sep 17 00:00:00 2001 From: Enrico Faulhaber Date: Wed, 31 Aug 2016 11:32:42 +0200 Subject: [PATCH] unsubscribe upon disconnect Change-Id: I45f53526b8f65741fede170a0420f0f4aabc00fb --- src/protocol/dispatcher.py | 3 ++- 1 file changed, 2 insertions(+), 1 deletion(-) diff --git a/src/protocol/dispatcher.py b/src/protocol/dispatcher.py index e537709..c424b61 100644 --- a/src/protocol/dispatcher.py +++ b/src/protocol/dispatcher.py @@ -145,7 +145,8 @@ class Dispatcher(object): """removes now longer functional connection""" if conn in self._dispatcher_connections: self._dispatcher_connections.remove(conn) - # XXX: also clean _dispatcher_subscriptions ! + for _evt, conns in self._dispatcher_subscriptions.items(): + conns.discard(conn) def register_device(self, devobj, devname, export=True): self.log.debug('registering Device %r as %s (export=%r)' %