yuanbiao
/
emqx
1
0
Code Issues Pull Requests Packages Projects Releases Wiki Activity

fix issue #155

This commit is contained in:
Feng Lee 2015-06-03 23:50:02 +08:00
parent 0044514a87
commit 053ddf6113
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
apps/emqtt/src/emqtt_parser.erl
View File

@ -196,7 +196,7 @@ wrap(Header, Rest) ->
% parse_qos(Rest, [QoS | Acc]). % parse_qos(Rest, [QoS | Acc]).
parse_topics(_, <<>>, Topics) -> parse_topics(_, <<>>, Topics) ->
Topics; lists:reverse(Topics);
parse_topics(?SUBSCRIBE = Sub, Bin, Topics) -> parse_topics(?SUBSCRIBE = Sub, Bin, Topics) ->
{Name, <<_:6, QoS:2, Rest/binary>>} = parse_utf(Bin), {Name, <<_:6, QoS:2, Rest/binary>>} = parse_utf(Bin),
parse_topics(Sub, Rest, [{Name, QoS}| Topics]); parse_topics(Sub, Rest, [{Name, QoS}| Topics]);