From ba1c276c75433c53902475a408733c842376b8a7 Mon Sep 17 00:00:00 2001 From: "Zaiming (Stone) Shi" Date: Wed, 5 Oct 2022 10:04:09 +0200 Subject: [PATCH] fix(typespec): fix type spec for emqx_shared_sub:redispatch_to --- src/emqx_shared_sub.erl | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/src/emqx_shared_sub.erl b/src/emqx_shared_sub.erl index 4987248cf..be897569a 100644 --- a/src/emqx_shared_sub.erl +++ b/src/emqx_shared_sub.erl @@ -85,6 +85,8 @@ -define(NO_ACK, no_ack). -define(REDISPATCH_TO(GROUP, TOPIC), {GROUP, TOPIC}). +-type redispatch_to() :: ?REDISPATCH_TO(emqx_topic:group(), emqx_topic:topic()). + -record(state, {pmon}). -record(emqx_shared_subscription, {group, topic, subpid}). @@ -245,7 +247,7 @@ is_redispatch_needed(Msg) -> %% @hidden Return the `redispatch_to` group-topic in the message header. %% `false` is returned if the message is not a shared dispatch. %% or when it's a QoS 0 message. --spec(get_redispatch_to(emqx_types:message()) -> emqx_types:topic() | false). +-spec(get_redispatch_to(emqx_types:message()) -> redispatch_to() | false). get_redispatch_to(Msg) -> emqx_message:get_header(redispatch_to, Msg, false).