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
{: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)