diff --git a/lib/membrane/hls/sink_bin.ex b/lib/membrane/hls/sink_bin.ex index fb4488f..12edcd1 100644 --- a/lib/membrane/hls/sink_bin.ex +++ b/lib/membrane/hls/sink_bin.ex @@ -225,7 +225,8 @@ defmodule Membrane.HLS.SinkBin do {[], state} end - def handle_child_notification(:flush, _, ctx, state) do + @impl true + def handle_parent_notification(:flush, ctx, state) do if not state.flush and all_streams_ended?(ctx, state.ended_sinks) do Agent.update(state.packager_pid, &Packager.flush/1, :infinity) {[notify_parent: :end_of_stream], state}