diff options
author | Devaev Maxim <[email protected]> | 2020-09-16 01:33:15 +0300 |
---|---|---|
committer | Devaev Maxim <[email protected]> | 2020-09-16 01:33:15 +0300 |
commit | 3f79f55a9ef6368b0bd2c76bf55c7e139ecfb9c7 (patch) | |
tree | d3b0275629da3075fdec805d17ccca802d859925 /kvmd/aiogp.py | |
parent | 00069931c181a672c7f709d9a76892e575a964f7 (diff) |
refactoring
Diffstat (limited to 'kvmd/aiogp.py')
-rw-r--r-- | kvmd/aiogp.py | 4 |
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(): |