Skip to content

Commit 3491cc7

Browse files
committed
Make flaky test not flaky
1 parent 9452a2a commit 3491cc7

File tree

1 file changed

+13
-3
lines changed

1 file changed

+13
-3
lines changed

test/membrane_http_adaptive_stream/integration_test/source_test.exs

Lines changed: 13 additions & 3 deletions
Original file line numberDiff line numberDiff line change
@@ -192,9 +192,7 @@ defmodule Membrane.HTTPAdaptiveStream.Source.Test do
192192
test "Live HLS stream played from the middle", %{tmp_dir: tmp_dir} do
193193
index_m3u8 = Path.join(tmp_dir, "index.m3u8")
194194
generate_live_hls(@bbb_33s_mp4_url, index_m3u8)
195-
196-
await_until_file_exists(index_m3u8)
197-
Process.sleep(20_000)
195+
:ok = await_until_media_sequence_is_3(index_m3u8)
198196

199197
spec =
200198
child(:hls_source, %Membrane.HTTPAdaptiveStream.Source{
@@ -253,6 +251,18 @@ defmodule Membrane.HTTPAdaptiveStream.Source.Test do
253251
end
254252
end
255253

254+
defp await_until_media_sequence_is_3(index_m3u8) do
255+
with {:ok, content} <- File.read(index_m3u8),
256+
true <- String.contains?(content, "#EXT-X-MEDIA-SEQUENCE:3") do
257+
:ok
258+
else
259+
_error ->
260+
Logger.debug("Waiting for media sequence to be 3...")
261+
Process.sleep(100)
262+
await_until_media_sequence_is_3(index_m3u8)
263+
end
264+
end
265+
256266
defp generate_live_hls(source_mp4, index_m3u8) do
257267
start_supervised!(
258268
{

0 commit comments

Comments
 (0)