From 53145bbbbabb7edb6c6e97c6937337f413402470 Mon Sep 17 00:00:00 2001 From: HuangDan Date: Thu, 6 Jul 2017 17:01:27 +0800 Subject: [PATCH] Update subscriptions/1 function spec --- src/emqttd.erl | 2 +- src/emqttd_server.erl | 2 +- 2 files changed, 2 insertions(+), 2 deletions(-) diff --git a/src/emqttd.erl b/src/emqttd.erl index 037c0de1a..c60f8d590 100644 --- a/src/emqttd.erl +++ b/src/emqttd.erl @@ -122,7 +122,7 @@ topics() -> emqttd_router:topics(). subscribers(Topic) -> emqttd_server:subscribers(iolist_to_binary(Topic)). --spec(subscriptions(subscriber()) -> [{binary(), suboption()}]). +-spec(subscriptions(subscriber()) -> [{binary(), binary(), list(suboption())}]). subscriptions(Subscriber) -> emqttd_server:subscriptions(Subscriber). diff --git a/src/emqttd_server.erl b/src/emqttd_server.erl index ec57f2802..ee79ac4fb 100644 --- a/src/emqttd_server.erl +++ b/src/emqttd_server.erl @@ -130,7 +130,7 @@ async_unsubscribe(Topic, Subscriber) when is_binary(Topic) -> setqos(Topic, Subscriber, Qos) when is_binary(Topic) -> call(pick(Subscriber), {setqos, Topic, Subscriber, Qos}). --spec(subscriptions(emqttd:subscriber()) -> [{binary(), list(emqttd:suboption())}]). +-spec(subscriptions(emqttd:subscriber()) -> [{binary(), binary(), list(emqttd:suboption())}]). subscriptions(Subscriber) -> lists:map(fun({_, {_Share, Topic}}) -> subscription(Topic, Subscriber);