summaryrefslogtreecommitdiff
path: root/kvmd
diff options
context:
space:
mode:
Diffstat (limited to 'kvmd')
-rw-r--r--kvmd/clients/streamer.py5
1 files changed, 4 insertions, 1 deletions
diff --git a/kvmd/clients/streamer.py b/kvmd/clients/streamer.py
index f26fed1e..b9847679 100644
--- a/kvmd/clients/streamer.py
+++ b/kvmd/clients/streamer.py
@@ -176,10 +176,13 @@ class MemsinkStreamerClient(BaseStreamerClient):
raise StreamerPermError("Missing ustreamer library")
try:
with ustreamer.Memsink(**self.__kwargs) as sink:
+ key_required = (self.__fmt == StreamFormats.H264)
while True:
- frame = await aiotools.run_async(sink.wait_frame)
+ frame = await aiotools.run_async(sink.wait_frame, key_required)
if frame is not None:
self.__check_format(frame["format"])
+ if frame["key"]:
+ key_required = False
yield frame
except StreamerPermError:
raise