assert stream_deleted is sent when stream ends

membraneframework · Oct 31, 2024 · 109f664 · 109f664
1 parent 726f791
commit 109f664
Showing 1 changed file with 3 additions and 1 deletion.
diff --git a/test/membrane_rtmp_plugin/rtmp_source_bin_test.exs b/test/membrane_rtmp_plugin/rtmp_source_bin_test.exs
@@ -53,9 +53,11 @@ defmodule Membrane.RTMP.SourceBin.IntegrationTest do
     assert_end_of_stream(pipeline, :audio_sink, :input)
     assert_end_of_stream(pipeline, :video_sink, :input)
 
+    assert :ok = Task.await(ffmpeg_task)
+    assert_pipeline_notified(pipeline, :src, :stream_deleted)
+
     # Cleanup
     Testing.Pipeline.terminate(pipeline)
-    assert :ok = Task.await(ffmpeg_task)
   end
 
   test "SourceBin doesn't output anything if the client tries to connect to different app or stream key" do