Use :erlang.start_timer instead of simple Process.send_after

Author: martosaur

lib/posthog/sender.ex

@@ -81,7 +81,7 @@ defmodule PostHog.Sender do
          {:continue, :send_batch}}
 
       %{num_events: 0, events: events} ->
-        ref = Process.send_after(self(), :batch_time_reached, state.max_batch_time_ms)
+        ref = :erlang.start_timer(state.max_batch_time_ms, self(), :batch_time_reached)
 
         {:noreply, %{state | events: [event | events], num_events: 1, timer_ref: ref}}
 
@@ -91,11 +91,12 @@ defmodule PostHog.Sender do
   end
 
   @impl GenServer
-  def handle_info(:batch_time_reached, %{num_events: n} = state) when n > 0 do
+  def handle_info({:timeout, ref, :batch_time_reached}, %{num_events: n, timer_ref: ref} = state)
+      when n > 0 do
     {:noreply, state, {:continue, :send_batch}}
   end
 
-  def handle_info(:batch_time_reached, state), do: {:noreply, state}
+  def handle_info({:timeout, _ref, :batch_time_reached}, state), do: {:noreply, state}
 
   @impl GenServer
   def handle_continue(:send_batch, state) do

test/posthog/sender_test.exs

@@ -249,10 +249,10 @@ defmodule PostHog.SenderTest do
       [{^pid, :busy}] = Registry.lookup(registry, {PostHog.Sender, 1})
       send(pid, :go)
       assert_receive :done
-      :sys.get_status(pid)
+      %{timer_ref: ref} = :sys.get_state(pid)
       [{^pid, :available}] = Registry.lookup(registry, {PostHog.Sender, 1})
 
-      send(pid, :batch_time_reached)
+      send(pid, {:timeout, ref, :batch_time_reached})
       refute_receive :ready
     end
   end