GithubFollow/One-KVM
1
0
Fork 0
mirror of https://github.com/mofeng-git/One-KVM.git synced 2025-12-12 01:00:29 +08:00
Code Issues Actions Packages Projects Releases Wiki Activity

refactoring

Browse Source
This commit is contained in:
Devaev Maxim 2020-09-16 01:33:15 +03:00
parent 00069931c1
commit 3f79f55a9e
1 changed files with 2 additions and 2 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

4
kvmd/aiogp.py
View File

@ -155,7 +155,7 @@ class _DebouncedValue:
self.__loop = loop self.__loop = loop
self.__queue: asyncio.queues.Queue = asyncio.Queue(loop=loop) self.__queue: asyncio.queues.Queue = asyncio.Queue(loop=loop)
self.__task = loop.create_task(self.__consumer()) self.__task = loop.create_task(self.__consumer_task_loop())
def set(self, value: bool) -> None: def set(self, value: bool) -> None:
if self.__loop.is_running(): if self.__loop.is_running():
@ -169,7 +169,7 @@ class _DebouncedValue:
if self.__task.done() and not self.__task.cancelled(): if self.__task.done() and not self.__task.cancelled():
raise RuntimeError("Dead debounce consumer") raise RuntimeError("Dead debounce consumer")
async def __consumer(self) -> None: async def __consumer_task_loop(self) -> None:
while True: while True:
value = await self.__queue.get() value = await self.__queue.get()
while not self.__queue.empty(): while not self.__queue.empty():