diff options
| author | Maxim Devaev <[email protected]> | 2022-08-07 19:04:32 +0300 |
|---|---|---|
| committer | Maxim Devaev <[email protected]> | 2022-08-07 19:04:32 +0300 |
| commit | ec9785b4be4afb8667e6968a0454aeca62a190e2 (patch) | |
| tree | 0b5c7d1b03041867c78f5533a8dd8f488711b073 /kvmd/plugins/msd/__init__.py | |
| parent | aa630988cc09f31d412a62c5480d4bec1a7c626e (diff) | |
simplified AioNotifier()
Diffstat (limited to 'kvmd/plugins/msd/__init__.py')
| -rw-r--r-- | kvmd/plugins/msd/__init__.py | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/kvmd/plugins/msd/__init__.py b/kvmd/plugins/msd/__init__.py index 753a1cd0..1e4a521e 100644 --- a/kvmd/plugins/msd/__init__.py +++ b/kvmd/plugins/msd/__init__.py @@ -218,7 +218,7 @@ class MsdFileReader(BaseMsdReader): # pylint: disable=too-many-instance-attribu now = time.monotonic() if self.__tick + 1 < now or self.__readed == self.__file_size: self.__tick = now - await self.__notifier.notify() + self.__notifier.notify() yield chunk @@ -277,7 +277,7 @@ class MsdFileWriter(BaseMsdWriter): # pylint: disable=too-many-instance-attribu now = time.monotonic() if self.__tick + 1 < now: self.__tick = now - await self.__notifier.notify() + self.__notifier.notify() return self.__written |