anlicheng/ekfa
1
0
Fork 0
Code Issues Pull Requests Actions Packages Projects Releases Wiki Activity

fix subscription

Browse Source
This commit is contained in:
anlicheng 2025-04-29 17:38:15 +08:00
parent fc338360b9
commit f9690fc81f
1 changed files with 3 additions and 0 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

3
apps/efka/src/efka_subscription.erl
View File

@ -13,6 +13,7 @@
%% API %% API
-export([start_link/0]). -export([start_link/0]).
-export([subscribe/2, publish/2]).
-export([match_components/2, match_topic/2, is_valid_components/1, of_components/1]). -export([match_components/2, match_topic/2, is_valid_components/1, of_components/1]).
%% gen_server callbacks %% gen_server callbacks
@ -35,9 +36,11 @@
%%% API %%% API
%%%=================================================================== %%%===================================================================
-spec subscribe(Topic :: binary(), SubscriberPid :: pid()) -> no_return().
subscribe(Topic, SubscriberPid) when is_binary(Topic), is_pid(SubscriberPid) -> subscribe(Topic, SubscriberPid) when is_binary(Topic), is_pid(SubscriberPid) ->
gen_server:cast(?SERVER, {subscribe, Topic, SubscriberPid}). gen_server:cast(?SERVER, {subscribe, Topic, SubscriberPid}).
-spec publish(Topic :: binary(), Content :: binary()) -> no_return().
publish(Topic, Content) when is_binary(Topic), is_binary(Content) -> publish(Topic, Content) when is_binary(Topic), is_binary(Content) ->
gen_server:cast(?SERVER, {publish, Topic, Content}). gen_server:cast(?SERVER, {publish, Topic, Content}).