kopia lustrzana https://github.com/Yakifo/amqtt
Merge pull request #59 from cfchou/dev1609
release PluginManager._fired_events if they are donepull/8/head
commit
be50891e76
|
@ -142,6 +142,7 @@ class PluginManager:
|
||||||
if tasks:
|
if tasks:
|
||||||
yield from asyncio.wait(tasks, loop=self._loop)
|
yield from asyncio.wait(tasks, loop=self._loop)
|
||||||
else:
|
else:
|
||||||
|
self._fired_events = [e for e in self._fired_events if not e.done()]
|
||||||
self._fired_events.extend(tasks)
|
self._fired_events.extend(tasks)
|
||||||
|
|
||||||
@asyncio.coroutine
|
@asyncio.coroutine
|
||||||
|
|
Ładowanie…
Reference in New Issue