🐛 Set messages_received_since_last_heartbeat

RTLS · RTLS · commit 83b99e5b41ac · 2025-03-11T17:54:49.000-07:00
diff --git a/lib/sequin/runtime/slot_processor_server.ex b/lib/sequin/runtime/slot_processor_server.ex
@@ -363,6 +363,7 @@ defmodule Sequin.Runtime.SlotProcessorServer do
       incr_counter(:raw_bytes_received_since_last_log, raw_bytes_received)
 
       state = maybe_schedule_flush(state)
+      state = %{state | message_received_since_last_heartbeat: true}
 
       state =
         Map.update!(state, :accumulated_msg_binaries, fn acc ->
