Revert "Add flush callback"

This reverts commit d1504a6.
kim-company · Aug 22, 2023 · a649112 · a649112
1 parent d1504a6
commit a649112
Show file tree

Hide file tree

Showing 3 changed files with 1 addition and 7 deletions.
diff --git a/lib/membrane/hls/segment_content_builder.ex b/lib/membrane/hls/segment_content_builder.ex
@@ -17,9 +17,6 @@ defprotocol Membrane.HLS.SegmentContentBuilder do
   @spec drop_buffers_in_segment(t(), Segment.t()) :: {t(), [Buffer.t()]}
   def drop_buffers_in_segment(impl, segment)
 
-  @spec flush(t()) :: t()
-  def flush(impl)
-
   @spec is_empty?(t()) :: boolean()
   def is_empty?(impl)
 end
diff --git a/lib/membrane/hls/sink.ex b/lib/membrane/hls/sink.ex
@@ -125,7 +125,7 @@ defmodule Membrane.HLS.Sink do
   def handle_end_of_stream(_pad, _ctx, state) do
     if state.timer != nil, do: Process.cancel_timer(state.timer)
 
-    flush_and_write_playlist(%{state | content_builder: SCB.flush(state.content_builder)}, [])
+    flush_and_write_playlist(state, [])
   end
 
   defp flush_and_write_playlist(state, acc) do

diff --git a/test/support/segment_content_builder.ex b/test/support/segment_content_builder.ex
@@ -34,9 +34,6 @@ defimpl Membrane.HLS.SegmentContentBuilder, for: Support.SegmentContentBuilder d
     {%SCB{acc: future}, valid}
   end
 
-  @impl true
-  def flush(state), do: state
-
   @impl true
   def is_empty?(state), do: Enum.empty?(state.acc)
 end