Comment due to CR

membraneframework · Mar 20, 2024 · 06ac9c9 · 06ac9c9
1 parent bd5f8f3
commit 06ac9c9
Showing 1 changed file with 5 additions and 1 deletion.
diff --git a/test/membrane/integration/delayed_demands_loop_test.exs b/test/membrane/integration/delayed_demands_loop_test.exs
@@ -54,7 +54,11 @@ defmodule Membrane.Test.DelayedDemandsLoopTest do
   end
 
   defp do_test(sinks_number) do
+    # auto_demand_size is smaller than delayed_demands_loop_counter_limit to ensure, that counter
+    # doesn't reset after calling handle_demand caused by reading positive atomic demand value
+    # during the snaphsot
     auto_demand_size = 15
+    requests_number = 20
 
     spec =
       [child(:source, Source)] ++
@@ -70,7 +74,7 @@ defmodule Membrane.Test.DelayedDemandsLoopTest do
       assert_start_of_stream(pipeline, {:sink, ^i})
     end
 
-    for _i <- 1..(auto_demand_size + 5) do
+    for _i <- 1..requests_number do
       Testing.Pipeline.notify_child(pipeline, :source, :request)
       assert_pipeline_notified(pipeline, :source, :response)
     end