Move send after outside if condition

upmaru · Oct 31, 2024 · 265c707 · 265c707
1 parent 6efeb9a
commit 265c707
Showing 1 changed file with 2 additions and 2 deletions.
diff --git a/lib/uplink/metrics/producer.ex b/lib/uplink/metrics/producer.ex
@@ -35,25 +35,25 @@ defmodule Uplink.Metrics.Producer do
 
   def handle_demand(demand, state) do
     Logger.info("[Metrics.Producer] handle demand #{DateTime.utc_now()}")
+    Process.send_after(self(), :poll, state.poll_interval)
 
     if ready_to_fetch?(state) do
       {messages, state} = load_metrics(demand, state)
       {:noreply, messages, state}
     else
-      Process.send_after(self(), :poll, state.poll_interval)
       {:noreply, [], state}
     end
   end
 
   @impl true
   def handle_info(:poll, state) do
     Logger.info("[Metrics.Producer] poll #{DateTime.utc_now()}")
+    Process.send_after(self(), :poll, state.poll_interval)
 
     if ready_to_fetch?(state) do
       {messages, state} = load_metrics(0, state)
       {:noreply, messages, state}
     else
-      Process.send_after(self(), :poll, state.poll_interval)
       {:noreply, [], state}
     end
   end