From 7467c25673120652b3c144dad3bf3ca9a279b53f Mon Sep 17 00:00:00 2001 From: =?utf8?q?Christopher=20Cot=C3=A9?= Date: Wed, 27 Jan 2021 19:40:57 -0600 Subject: [PATCH] fix dialyzer error --- lib/cluster_kv/ring.ex | 8 ++++++-- 1 file changed, 6 insertions(+), 2 deletions(-) diff --git a/lib/cluster_kv/ring.ex b/lib/cluster_kv/ring.ex index 198959e..5a8c2e0 100644 --- a/lib/cluster_kv/ring.ex +++ b/lib/cluster_kv/ring.ex @@ -588,10 +588,14 @@ defmodule ClusterKV.Ring do @spec send_sync( name :: module(), - nodes :: [node()], - key :: {String.t(), String.t()}, + nodes :: [node()] | {:error, {:invalid_ring, :no_nodes}}, + key :: binary(), value :: any() ) :: :ok + defp send_sync(_name, {:error, er}, _key, _value) do + Logger.warn("No nodes to sync with, #{inspect(er)}") + end + defp send_sync(name, nodes, key, value) do Enum.each(nodes, fn n -> send({name, n}, {:sync, key, value}) -- 2.45.3