fix: set a lower fullsweep_after flag for GenRpcPubSub workers (#1551)

Author: edgurgel

lib/realtime/gen_rpc/pub_sub.ex

@@ -67,6 +67,7 @@ defmodule Realtime.GenRpcPubSub.Worker do
   @impl true
   def init(pubsub) do
     Process.flag(:message_queue_data, :off_heap)
+    Process.flag(:fullsweep_after, 1000)
     {:ok, pubsub}
   end
 

mix.exs

@@ -4,7 +4,7 @@ defmodule Realtime.MixProject do
   def project do
     [
       app: :realtime,
-      version: "2.51.8",
+      version: "2.51.9",
       elixir: "~> 1.17.3",
       elixirc_paths: elixirc_paths(Mix.env()),
       start_permanent: Mix.env() == :prod,

test/realtime/gen_rpc_pub_sub_test.exs

@@ -9,4 +9,10 @@ defmodule Realtime.GenRpcPubSubTest do
            |> Process.whereis()
            |> Process.info(:message_queue_data) == {:message_queue_data, :off_heap}
   end
+
+  test "it sets fullsweep_after flag on the workers" do
+    assert Realtime.PubSubElixir.Realtime.PubSub.Adapter_1
+           |> Process.whereis()
+           |> Process.info(:fullsweep_after) == {:fullsweep_after, 1000}
+  end
 end