fix dialyzer

supabase · Nov 19, 2024 · 947f820 · 947f820
1 parent ca150a2
commit 947f820
Showing 1 changed file with 4 additions and 1 deletion.
diff --git a/lib/realtime/database.ex b/lib/realtime/database.ex
@@ -228,9 +228,12 @@ defmodule Realtime.Database do
   @doc """
   Runs database transaction in local node or against a target node withing a Postgrex transaction
   """
-  @spec transaction(pid, fun(), keyword()) :: {:ok, any()} | {:error, any()}
+  @spec transaction(pid | DBConnection.t(), fun(), keyword()) :: {:ok, any()} | {:error, any()}
   def transaction(db_conn, func, opts \\ [], metadata \\ [])
 
+  def transaction(%DBConnection{} = db_conn, func, opts, metadata),
+    do: transaction_catched(db_conn, func, opts, metadata)
+
   def transaction(db_conn, func, opts, metadata) when node() == node(db_conn),
     do: transaction_catched(db_conn, func, opts, metadata)