diff options
| author | Devaev Maxim <[email protected]> | 2020-09-10 12:33:26 +0300 |
|---|---|---|
| committer | Devaev Maxim <[email protected]> | 2020-09-10 12:33:26 +0300 |
| commit | 1d98f5ed046a5333aadc2abbef11dbb371f905f3 (patch) | |
| tree | 39ee585f19dab2ab4ddb64aadf06618eef8d58a0 /kvmd/aiotools.py | |
| parent | 23ad91060670a980bff2ebf5ea6356ebedd89411 (diff) | |
experimental edge mode
Diffstat (limited to 'kvmd/aiotools.py')
| -rw-r--r-- | kvmd/aiotools.py | 3 |
1 files changed, 3 insertions, 0 deletions
diff --git a/kvmd/aiotools.py b/kvmd/aiotools.py index 84c6f314..dfd67f44 100644 --- a/kvmd/aiotools.py +++ b/kvmd/aiotools.py @@ -97,6 +97,9 @@ class AioNotifier: async def notify(self) -> None: await self.__queue.put(None) + def notify_sync(self) -> None: + self.__queue.put_nowait(None) + async def wait(self) -> None: await self.__queue.get() while not self.__queue.empty(): |