summaryrefslogtreecommitdiff
path: root/kvmd/clients/streamer.py
diff options
context:
space:
mode:
authorDevaev Maxim <[email protected]>2020-05-18 13:34:23 +0300
committerDevaev Maxim <[email protected]>2020-05-18 13:34:23 +0300
commit028e0b06ff6730e309e1d3c7fb6abebb81360f5b (patch)
tree981760a61c3645ad85b6327dadbde3194d31c9e2 /kvmd/clients/streamer.py
parent3947640771a8d212e13196808679ba3caa1c411d (diff)
refactoring
Diffstat (limited to 'kvmd/clients/streamer.py')
-rw-r--r--kvmd/clients/streamer.py4
1 files changed, 3 insertions, 1 deletions
diff --git a/kvmd/clients/streamer.py b/kvmd/clients/streamer.py
index e8051855..e38497e5 100644
--- a/kvmd/clients/streamer.py
+++ b/kvmd/clients/streamer.py
@@ -26,6 +26,8 @@ from typing import AsyncGenerator
import aiohttp
+from .. import aiotools
+
# =====
class StreamerError(Exception):
@@ -59,7 +61,7 @@ class StreamerClient:
params={"extra_headers": "1"},
headers={"User-Agent": self.__user_agent},
) as response:
- response.raise_for_status()
+ aiotools.raise_not_200(response)
reader = aiohttp.MultipartReader.from_response(response)
while True:
frame = await reader.next() # pylint: disable=not-callable