From 549799a86f1852717f10c85a27cb44d8786c34d7 Mon Sep 17 00:00:00 2001 From: =?utf8?q?Christopher=20Cot=C3=A9?= Date: Wed, 27 Jan 2021 15:06:15 -0600 Subject: [PATCH] update batch upsert function --- lib/cluster_kv/db.ex | 2 +- 1 file changed, 1 insertion(+), 1 deletion(-) diff --git a/lib/cluster_kv/db.ex b/lib/cluster_kv/db.ex index 734e70c..b0301b9 100644 --- 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) -- 2.45.3