From 488ff01041dcbaeb4651d7db0ceb2fbb96e43342 Mon Sep 17 00:00:00 2001 From: Chifeng Chou Date: Thu, 17 Nov 2016 12:28:09 +0800 Subject: [PATCH] release PluginManager._fired_events if they are done --- hbmqtt/plugins/manager.py | 1 + 1 file changed, 1 insertion(+) diff --git a/hbmqtt/plugins/manager.py b/hbmqtt/plugins/manager.py index 76ca38a..ac4c2c4 100644 --- a/hbmqtt/plugins/manager.py +++ b/hbmqtt/plugins/manager.py @@ -142,6 +142,7 @@ class PluginManager: if tasks: yield from asyncio.wait(tasks, loop=self._loop) else: + self._fired_events = [e for e in self._fired_events if not e.done()] self._fired_events.extend(tasks) @asyncio.coroutine