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

unsubscribe function should have two params

This commit is contained in:
Gilbert Wong 2018-08-27 17:11:54 +08:00
parent c5da439313
commit 224aaaf8a7
1 changed files with 1 additions and 1 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

2
src/emqx.erl
View File

@ -95,7 +95,7 @@ unsubscribe(Topic) ->
-spec(unsubscribe(topic() | string(), subscriber() | string()) -> ok | {error, term()}). -spec(unsubscribe(topic() | string(), subscriber() | string()) -> ok | {error, term()}).
unsubscribe(Topic, Sub) when is_list(Sub) -> unsubscribe(Topic, Sub) when is_list(Sub) ->
emqx_broker:unsubscribe(iolist_to_binary(Topic)); emqx_broker:unsubscribe(iolist_to_binary(Topic), list_to_subid(Sub));
unsubscribe(Topic, Subscriber) when is_tuple(Subscriber) -> unsubscribe(Topic, Subscriber) when is_tuple(Subscriber) ->
{SubPid, SubId} = Subscriber, {SubPid, SubId} = Subscriber,
emqx_broker:unsubscribe(iolist_to_binary(Topic), SubPid, SubId). emqx_broker:unsubscribe(iolist_to_binary(Topic), SubPid, SubId).