We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
1 parent f33c781 commit 6715aeaCopy full SHA for 6715aea
packages/sync-service/lib/electric/shapes/consumer.ex
@@ -342,6 +342,11 @@ defmodule Electric.Shapes.Consumer do
342
{:noreply, state, state.hibernate_after}
343
end
344
345
+ def handle_info({:global_last_seen_lsn, _lsn}, %{event_handler: nil} = state) do
346
+ # Consumer not yet initialized, ignore
347
+ {:noreply, state}
348
+ end
349
+
350
def handle_info({:global_last_seen_lsn, _lsn} = event, state) do
351
case handle_event(event, state) do
352
%{terminating?: true} = state ->
0 commit comments