From 68d105398e837592190ee41a4bc5afebce339a21 Mon Sep 17 00:00:00 2001 From: Philip Giuliani Date: Wed, 9 Oct 2024 12:41:32 +0200 Subject: [PATCH] Change end of stream based on flush status --- lib/membrane/hls/sink_bin.ex | 4 ++-- 1 file changed, 2 insertions(+), 2 deletions(-) diff --git a/lib/membrane/hls/sink_bin.ex b/lib/membrane/hls/sink_bin.ex index cae0b5f..d91cd01 100644 --- a/lib/membrane/hls/sink_bin.ex +++ b/lib/membrane/hls/sink_bin.ex @@ -180,7 +180,7 @@ defmodule Membrane.HLS.SinkBin do if state.flush, do: Packager.flush(state.opts.packager) - {[notify_parent: :end_of_stream], state} + {[notify_parent: {:end_of_stream, state.flush}], state} else {[], %{state | ended_sinks: ended_sinks}} end @@ -194,7 +194,7 @@ defmodule Membrane.HLS.SinkBin do def handle_parent_notification(:flush, ctx, state) do if not state.flush and all_streams_ended?(ctx, state.ended_sinks) do Packager.flush(state.opts.packager) - {[notify_parent: :end_of_stream], %{state | flush: true}} + {[notify_parent: {:end_of_stream, true}], %{state | flush: true}} else {[], %{state | flush: true}} end