]> Entropealabs - cluster_kv.git/commitdiff
remove unused argument
authorChristopher <chris@entropealabs.com>
Sun, 8 Mar 2020 02:46:17 +0000 (20:46 -0600)
committerChristopher <chris@entropealabs.com>
Sun, 8 Mar 2020 02:46:17 +0000 (20:46 -0600)
lib/cluster_kv/db.ex

index 6012b93946c164259c2931f05d7b57e6abe6af7d..df91ffee49b2f39e6eb9c749d2c3089bcdfc1ffe 100644 (file)
@@ -27,8 +27,8 @@ defmodule ClusterKV.DB do
     GenServer.cast(name, {:upsert, key, value, fun})
   end
 
-  def batch(name, batch, fun \\ &{elem(&1, 0), Enum.uniq([&2 | elem(&1, 1)])}) do
-    GenServer.cast(name, {:batch, batch, fun})
+  def batch(name, batch) do
+    GenServer.cast(name, {:batch, batch})
   end
 
   def stream(name, timeout \\ :infinity) do
@@ -63,7 +63,7 @@ defmodule ClusterKV.DB do
     {:noreply, state}
   end
 
-  def handle_cast({:batch, batch, fun}, %DB{db: db} = state) do
+  def handle_cast({:batch, batch}, %DB{db: db} = state) do
     Enum.each(batch, fn {k, v} ->
       :ets.insert(db, {k, [v]})
     end)