summaryrefslogtreecommitdiff
path: root/kvmd/aiogp.py
diff options
context:
space:
mode:
authorDevaev Maxim <[email protected]>2020-09-16 01:33:15 +0300
committerDevaev Maxim <[email protected]>2020-09-16 01:33:15 +0300
commit3f79f55a9ef6368b0bd2c76bf55c7e139ecfb9c7 (patch)
treed3b0275629da3075fdec805d17ccca802d859925 /kvmd/aiogp.py
parent00069931c181a672c7f709d9a76892e575a964f7 (diff)
refactoring
Diffstat (limited to 'kvmd/aiogp.py')
-rw-r--r--kvmd/aiogp.py4
1 files changed, 2 insertions, 2 deletions
diff --git a/kvmd/aiogp.py b/kvmd/aiogp.py
index e696787c..aa7c2778 100644
--- a/kvmd/aiogp.py
+++ b/kvmd/aiogp.py
@@ -155,7 +155,7 @@ class _DebouncedValue:
self.__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:
if self.__loop.is_running():
@@ -169,7 +169,7 @@ class _DebouncedValue:
if self.__task.done() and not self.__task.cancelled():
raise RuntimeError("Dead debounce consumer")
- async def __consumer(self) -> None:
+ async def __consumer_task_loop(self) -> None:
while True:
value = await self.__queue.get()
while not self.__queue.empty():