feat(queue): fix dialyzer issues

apps/emqx/src/emqx_persistent_session_ds/emqx_persistent_session_ds_shared_subs_null_agent.erl

@@ -37,7 +37,7 @@ on_unsubscribe(Agent, _TopicFilter) ->
     Agent.
 
 renew_streams(Agent) ->
-    {[], [], Agent}.
+    {[], Agent}.
 
 on_stream_progress(Agent, _StreamProgress) ->
     Agent.

apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_leader_sup.erl

@@ -41,7 +41,7 @@ start_leader(Options) ->
     ChildSpec = emqx_ds_shared_sub_leader:child_spec(Options),
     supervisor:start_child(?MODULE, ChildSpec).
 
--spec stop_leader(emqx_ds_shared_sub_leader:topic_filter()) -> ok | {error, term()}.
+-spec stop_leader(emqx_persistent_session_ds:share_topic_filter()) -> ok | {error, term()}.
 stop_leader(TopicFilter) ->
     supervisor:terminate_child(?MODULE, emqx_ds_shared_sub_leader:id(TopicFilter)).
 

apps/emqx_ds_shared_sub/src/emqx_ds_shared_sub_registry.erl

@@ -25,7 +25,7 @@
 ]).
 
 -record(lookup_leader, {
-    agent :: emqx_ds_shared_sub:agent(),
+    agent :: emqx_ds_shared_sub_proto:agent(),
     topic_filter :: emqx_persistent_session_ds:share_topic_filter()
 }).
 
@@ -33,6 +33,9 @@
 %% API
 %%--------------------------------------------------------------------
 
+-spec lookup_leader(
+    emqx_ds_shared_sub_proto:agent(), emqx_persistent_session_ds:share_topic_filter()
+) -> ok.
 lookup_leader(Agent, TopicFilter) ->
     gen_server:cast(?MODULE, #lookup_leader{agent = Agent, topic_filter = TopicFilter}).