diff options
Diffstat (limited to 'kvmd/aiotools.py')
| -rw-r--r-- | kvmd/aiotools.py | 9 |
1 files changed, 3 insertions, 6 deletions
diff --git a/kvmd/aiotools.py b/kvmd/aiotools.py index 2a798e2a..07981fde 100644 --- a/kvmd/aiotools.py +++ b/kvmd/aiotools.py @@ -232,10 +232,7 @@ class AioNotifier: def __init__(self) -> None: self.__queue: "asyncio.Queue[None]" = asyncio.Queue() - async def notify(self) -> None: - await self.__queue.put(None) - - def notify_sync(self) -> None: + def notify(self) -> None: self.__queue.put_nowait(None) async def wait(self, timeout: Optional[float]=None) -> None: @@ -299,7 +296,7 @@ class AioExclusiveRegion: self.__busy = True try: if self.__notifier: - await self.__notifier.notify() + self.__notifier.notify() except: # noqa: E722 self.__busy = False raise @@ -309,7 +306,7 @@ class AioExclusiveRegion: async def exit(self) -> None: self.__busy = False if self.__notifier: - await self.__notifier.notify() + self.__notifier.notify() async def __aenter__(self) -> None: await self.enter() |