From f9690fc81f5eaca89fe39f6165debd7ae18a2044 Mon Sep 17 00:00:00 2001
From: anlicheng <244108715@qq.com>
Date: Tue, 29 Apr 2025 17:38:15 +0800
Subject: [PATCH] fix subscription

---
 apps/efka/src/efka_subscription.erl | 3 +++
 1 file changed, 3 insertions(+)

diff --git a/apps/efka/src/efka_subscription.erl b/apps/efka/src/efka_subscription.erl
index 04a866c..c16add0 100644
--- a/apps/efka/src/efka_subscription.erl
+++ b/apps/efka/src/efka_subscription.erl
@@ -13,6 +13,7 @@
 
 %% API
 -export([start_link/0]).
+-export([subscribe/2, publish/2]).
 -export([match_components/2, match_topic/2, is_valid_components/1, of_components/1]).
 
 %% gen_server callbacks
@@ -35,9 +36,11 @@
 %%% API
 %%%===================================================================
 
+-spec subscribe(Topic :: binary(), SubscriberPid :: pid()) -> no_return().
 subscribe(Topic, SubscriberPid) when is_binary(Topic), is_pid(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) ->
     gen_server:cast(?SERVER, {publish, Topic, Content}).