Fixes catch-up events creation in reverse order

quantum-elixir · Jun 16, 2020 · aaa50f4 · aaa50f4
1 parent 5a02a0b
commit aaa50f4
Showing 1 changed file with 2 additions and 0 deletions.
diff --git a/lib/quantum/clock_broadcaster.ex b/lib/quantum/clock_broadcaster.ex
@@ -72,6 +72,8 @@ defmodule Quantum.ClockBroadcaster do
         end
       )
 
+    events = Enum.reverse(events)
+
     new_remaining_demand = expected_event_count - Enum.count(events)
 
     if remaining_demand > 0 and new_remaining_demand == 0 do