summaryrefslogtreecommitdiff
path: root/kvmd/clients/streamer.py
diff options
context:
space:
mode:
authorDevaev Maxim <[email protected]>2020-05-28 11:03:49 +0300
committerDevaev Maxim <[email protected]>2020-05-28 11:03:49 +0300
commit1c93f6a562d1c2106d148cebb128397989fb84fd (patch)
tree8065e45b9a07004b5823d8f57a3272796aeb2704 /kvmd/clients/streamer.py
parentfbdfb009a1f752236eeacc8c2528167a64d5d3a8 (diff)
refactoring
Diffstat (limited to 'kvmd/clients/streamer.py')
-rw-r--r--kvmd/clients/streamer.py6
1 files changed, 3 insertions, 3 deletions
diff --git a/kvmd/clients/streamer.py b/kvmd/clients/streamer.py
index 7a56556b..493ac080 100644
--- a/kvmd/clients/streamer.py
+++ b/kvmd/clients/streamer.py
@@ -26,7 +26,7 @@ from typing import AsyncGenerator
import aiohttp
-from .. import aiotools
+from .. import htclient
# =====
@@ -59,7 +59,7 @@ class StreamerClient:
url=self.__make_url("stream"),
params={"extra_headers": "1"},
) as response:
- aiotools.raise_not_200(response)
+ htclient.raise_not_200(response)
reader = aiohttp.MultipartReader.from_response(response)
while True:
@@ -87,7 +87,7 @@ class StreamerClient:
# async def get_snapshot(self) -> Tuple[bool, bytes]:
# async with self.__make_http_session(infinite=False) as session:
# async with session.get(self.__make_url("snapshot")) as response:
-# aiotools.raise_not_200(response)
+# htclient.raise_not_200(response)
# return (
# (response.headers["X-UStreamer-Online"] == "true"),
# bytes(await response.read()),