diff --git a/lib/postgrex/parameters.ex b/lib/postgrex/parameters.ex index 210452e2..99935a6b 100644 --- a/lib/postgrex/parameters.ex +++ b/lib/postgrex/parameters.ex @@ -60,6 +60,7 @@ defmodule Postgrex.Parameters do end def handle_cast({:delete, ref}, state) do + Process.demonitor(ref, [:flush]) :ets.delete(state, ref) {:noreply, state} end