chore(gw): fix elvis warnings
This commit is contained in:
parent
561c95c31a
commit
52c78974d6
|
@ -246,7 +246,7 @@ handle_call({subscribe, Topic, SubOpts}, _From,
|
||||||
[ClientInfo, MountedTopic, NSubOpts]),
|
[ClientInfo, MountedTopic, NSubOpts]),
|
||||||
%% modifty session state
|
%% modifty session state
|
||||||
SubReq = {Topic, Token},
|
SubReq = {Topic, Token},
|
||||||
TempMsg = #coap_message{},
|
TempMsg = #coap_message{type = non},
|
||||||
Result = emqx_coap_session:process_subscribe(
|
Result = emqx_coap_session:process_subscribe(
|
||||||
SubReq, TempMsg, #{}, Session),
|
SubReq, TempMsg, #{}, Session),
|
||||||
NSession = maps:get(session, Result),
|
NSession = maps:get(session, Result),
|
||||||
|
@ -265,7 +265,7 @@ handle_call({unsubscribe, Topic}, _From,
|
||||||
|
|
||||||
%% modifty session state
|
%% modifty session state
|
||||||
UnSubReq = Topic,
|
UnSubReq = Topic,
|
||||||
TempMsg = #coap_message{},
|
TempMsg = #coap_message{type = non},
|
||||||
Result = emqx_coap_session:process_subscribe(
|
Result = emqx_coap_session:process_subscribe(
|
||||||
UnSubReq, TempMsg, #{}, Session),
|
UnSubReq, TempMsg, #{}, Session),
|
||||||
NSession = maps:get(session, Result),
|
NSession = maps:get(session, Result),
|
||||||
|
|
|
@ -272,7 +272,7 @@ ret_gw(GwName, {ok, #{raw_config := GwConf}}) ->
|
||||||
lists:map(fun({LName, LConf}) ->
|
lists:map(fun({LName, LConf}) ->
|
||||||
do_convert_listener2(GwName, LType, LName, LConf)
|
do_convert_listener2(GwName, LType, LName, LConf)
|
||||||
end, maps:to_list(SubConf)),
|
end, maps:to_list(SubConf)),
|
||||||
[NLConfs|Acc]
|
[NLConfs | Acc]
|
||||||
end, [], maps:to_list(LsConf)),
|
end, [], maps:to_list(LsConf)),
|
||||||
{ok, maps:merge(GwConf1, #{<<"listeners">> => NLsConf})};
|
{ok, maps:merge(GwConf1, #{<<"listeners">> => NLsConf})};
|
||||||
ret_gw(_GwName, Err) -> Err.
|
ret_gw(_GwName, Err) -> Err.
|
||||||
|
|
Loading…
Reference in New Issue