From ec456dcc7315a440b66714e28e74fcff1b495d07 Mon Sep 17 00:00:00 2001 From: terry-xiaoyu <506895667@qq.com> Date: Fri, 31 Aug 2018 20:48:26 +0800 Subject: [PATCH] Fix dialyze issue --- src/emqx_base62.erl | 3 +-- src/emqx_bridge.erl | 4 ++-- src/emqx_bridge_sup.erl | 2 +- 3 files changed, 4 insertions(+), 5 deletions(-) diff --git a/src/emqx_base62.erl b/src/emqx_base62.erl index 690115ec2..1a9db245a 100644 --- a/src/emqx_base62.erl +++ b/src/emqx_base62.erl @@ -22,7 +22,7 @@ %% @doc Encode any data to base62 binary -spec encode(string() | integer() - | binary()) -> float(). + | binary()) -> binary(). encode(I) when is_integer(I) -> encode(integer_to_binary(I)); encode(S) when is_list(S)-> @@ -110,4 +110,3 @@ decode_char(I) when I >= $A andalso I =< $Z-> decode_char(9, I) -> I + 61 - $A. - diff --git a/src/emqx_bridge.erl b/src/emqx_bridge.erl index 0f64f331d..a7ce2581d 100644 --- a/src/emqx_bridge.erl +++ b/src/emqx_bridge.erl @@ -117,7 +117,7 @@ handle_info(start, State = #state{options = Options, {noreply, State#state{client_pid = ClientPid}}; {error,_} -> erlang:send_after(ReconnectTime, self(), start), - {noreply, State = #state{reconnect_count = ReconnectCount-1}} + {noreply, State#state{reconnect_count = ReconnectCount-1}} end; %%---------------------------------------------------------------- @@ -138,7 +138,7 @@ handle_info(start, State = #state{options = Options, {noreply, State#state{client_pid = ClientPid}}; {error,_} -> erlang:send_after(ReconnectTime, self(), start), - {noreply, State = #state{reconnect_count = ReconnectCount-1}} + {noreply, State#state{reconnect_count = ReconnectCount-1}} end; %%---------------------------------------------------------------- diff --git a/src/emqx_bridge_sup.erl b/src/emqx_bridge_sup.erl index 0d8a0d887..bc8c0a532 100644 --- a/src/emqx_bridge_sup.erl +++ b/src/emqx_bridge_sup.erl @@ -27,7 +27,7 @@ start_link() -> supervisor:start_link({local, ?MODULE}, ?MODULE, []). %% @doc List all bridges --spec(bridges() -> [{node(), emqx_topic:topic(), pid()}]). +-spec(bridges() -> [{node(), Status :: binary()}]). bridges() -> [{Name, emqx_bridge:status(Pid)} || {Name, Pid, _, _} <- supervisor:which_children(?MODULE)].