From b56a158a545d387f12942e5ebaf54b70059172d7 Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Tue, 25 Apr 2023 14:29:40 -0300 Subject: [PATCH] fix(pulsar): fix function return typespec --- .../src/emqx_bridge_pulsar_impl_producer.erl | 5 ++++- 1 file changed, 4 insertions(+), 1 deletion(-) diff --git a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl index 0b195df66..2bd44d16a 100644 --- a/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl +++ b/apps/emqx_bridge_pulsar/src/emqx_bridge_pulsar_impl_producer.erl @@ -137,7 +137,10 @@ on_get_status(_InstanceId, State) -> disconnected end. --spec on_query(manager_id(), {send_message, map()}, state()) -> ok | {error, timeout}. +-spec on_query(manager_id(), {send_message, map()}, state()) -> + {ok, term()} + | {error, timeout} + | {error, term()}. on_query(_InstanceId, {send_message, Message}, State) -> #{ producers := Producers,