Change end of stream based on flush status

kim-company · Oct 9, 2024 · 68d1053 · 68d1053
1 parent 1252a3a
commit 68d1053
Showing 1 changed file with 2 additions and 2 deletions.
diff --git 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