update batch upsert function

diff --git a/lib/cluster_kv/db.ex b/lib/cluster_kv/db.ex
index 734e70ce86e2e07bde847a0599a34f9615128b19..b0301b9d2c55e1b2ccf0b9543c1dadd5114c4104 100644 (file)
--- a/lib/cluster_kv/db.ex
+++ b/lib/cluster_kv/db.ex
@@ -73,7 +73,7 @@ defmodule ClusterKV.DB do
           chunk :: integer(),
           fun :: update_function()
         ) :: :ok
-  def batch(name, batch, chunk \\ 10, fun \\ &{elem(&1, 0), Enum.uniq([elem(&1, 1) | &2])}) do
+  def batch(name, batch, chunk \\ 10, fun \\ &{elem(&1, 0), Enum.uniq(elem(&1, 1) ++ &2)}) do
     :poolboy.transaction(name, fn w ->
       GenServer.cast(w, {:batch, batch, chunk, fun})
     end)