Fix dialyze issue
This commit is contained in:
parent
2f63b7a487
commit
ec456dcc73
|
@ -22,7 +22,7 @@
|
||||||
%% @doc Encode any data to base62 binary
|
%% @doc Encode any data to base62 binary
|
||||||
-spec encode(string()
|
-spec encode(string()
|
||||||
| integer()
|
| integer()
|
||||||
| binary()) -> float().
|
| binary()) -> binary().
|
||||||
encode(I) when is_integer(I) ->
|
encode(I) when is_integer(I) ->
|
||||||
encode(integer_to_binary(I));
|
encode(integer_to_binary(I));
|
||||||
encode(S) when is_list(S)->
|
encode(S) when is_list(S)->
|
||||||
|
@ -110,4 +110,3 @@ decode_char(I) when I >= $A andalso I =< $Z->
|
||||||
|
|
||||||
decode_char(9, I) ->
|
decode_char(9, I) ->
|
||||||
I + 61 - $A.
|
I + 61 - $A.
|
||||||
|
|
||||||
|
|
|
@ -117,7 +117,7 @@ handle_info(start, State = #state{options = Options,
|
||||||
{noreply, State#state{client_pid = ClientPid}};
|
{noreply, State#state{client_pid = ClientPid}};
|
||||||
{error,_} ->
|
{error,_} ->
|
||||||
erlang:send_after(ReconnectTime, self(), start),
|
erlang:send_after(ReconnectTime, self(), start),
|
||||||
{noreply, State = #state{reconnect_count = ReconnectCount-1}}
|
{noreply, State#state{reconnect_count = ReconnectCount-1}}
|
||||||
end;
|
end;
|
||||||
|
|
||||||
%%----------------------------------------------------------------
|
%%----------------------------------------------------------------
|
||||||
|
@ -138,7 +138,7 @@ handle_info(start, State = #state{options = Options,
|
||||||
{noreply, State#state{client_pid = ClientPid}};
|
{noreply, State#state{client_pid = ClientPid}};
|
||||||
{error,_} ->
|
{error,_} ->
|
||||||
erlang:send_after(ReconnectTime, self(), start),
|
erlang:send_after(ReconnectTime, self(), start),
|
||||||
{noreply, State = #state{reconnect_count = ReconnectCount-1}}
|
{noreply, State#state{reconnect_count = ReconnectCount-1}}
|
||||||
end;
|
end;
|
||||||
|
|
||||||
%%----------------------------------------------------------------
|
%%----------------------------------------------------------------
|
||||||
|
|
|
@ -27,7 +27,7 @@ start_link() ->
|
||||||
supervisor:start_link({local, ?MODULE}, ?MODULE, []).
|
supervisor:start_link({local, ?MODULE}, ?MODULE, []).
|
||||||
|
|
||||||
%% @doc List all bridges
|
%% @doc List all bridges
|
||||||
-spec(bridges() -> [{node(), emqx_topic:topic(), pid()}]).
|
-spec(bridges() -> [{node(), Status :: binary()}]).
|
||||||
bridges() ->
|
bridges() ->
|
||||||
[{Name, emqx_bridge:status(Pid)} || {Name, Pid, _, _} <- supervisor:which_children(?MODULE)].
|
[{Name, emqx_bridge:status(Pid)} || {Name, Pid, _, _} <- supervisor:which_children(?MODULE)].
|
||||||
|
|
||||||
|
|
Loading…
Reference in New Issue