Remove duplicated finalize_stream code in stream (#42171)

This commit is contained in:
uvjustin
2020-10-22 05:36:54 +08:00
committed by GitHub
parent 8e063e94da
commit 6a59e79bc6

View File

@@ -160,10 +160,6 @@ def _stream_worker_internal(hass, stream, quit_event):
audio_stream = None audio_stream = None
except (av.AVError, StopIteration) as ex: except (av.AVError, StopIteration) as ex:
if not stream.keepalive:
# End of stream, clear listeners and stop thread
for fmt, _ in outputs.items():
hass.loop.call_soon_threadsafe(stream.outputs[fmt].put, None)
_LOGGER.error( _LOGGER.error(
"Error demuxing stream while finding first packet: %s", str(ex) "Error demuxing stream while finding first packet: %s", str(ex)
) )