From b3d795c523380606c2bef56101ef8668e12040a9 Mon Sep 17 00:00:00 2001 From: anlicheng <244108715@qq.com> Date: Sun, 19 Apr 2026 17:31:19 +0800 Subject: [PATCH] fix format --- src/endpoint/endpoint_subscription.erl | 2 ++ 1 file changed, 2 insertions(+) diff --git a/src/endpoint/endpoint_subscription.erl b/src/endpoint/endpoint_subscription.erl index 0369af0..8dfcbc2 100644 --- a/src/endpoint/endpoint_subscription.erl +++ b/src/endpoint/endpoint_subscription.erl @@ -90,6 +90,7 @@ init([]) -> %% 同一个SubscriberPid只能订阅同一个topic一次 handle_call(get_subscribers, _From, State = #state{subscribers = Subscribers}) -> {reply, {ok, Subscribers}, State}; + handle_call({subscribe, Topic, SubscriberPid}, _From, State = #state{subscribers = Subscribers}) -> Components = of_components(Topic), case is_valid_components(Components) of @@ -112,6 +113,7 @@ handle_call({subscribe, Topic, SubscriberPid}, _From, State = #state{subscribers false -> {reply, {error, <<"invalid topic name">>}, State} end; + handle_call({unsubscribe, Topic, SubscriberPid}, _From, State = #state{subscribers = Subscribers}) -> {Removed, Reserved} = lists:partition(fun(#subscriber{topic = Topic0, subscriber_pid = SubscriberPid0}) -> Topic =:= Topic0 andalso SubscriberPid =:= SubscriberPid0