From 2274a192cc47f1911f04fafcd5fdc9c804a5ea73 Mon Sep 17 00:00:00 2001 From: Stefan Strigler Date: Mon, 26 Jun 2023 16:46:35 +0200 Subject: [PATCH] fix(emqx_resource): call async reply fun in simple_aysnc_query --- apps/emqx_resource/src/emqx_resource_buffer_worker.erl | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/apps/emqx_resource/src/emqx_resource_buffer_worker.erl b/apps/emqx_resource/src/emqx_resource_buffer_worker.erl index a8d9a6c15..c7fd8a965 100644 --- a/apps/emqx_resource/src/emqx_resource_buffer_worker.erl +++ b/apps/emqx_resource/src/emqx_resource_buffer_worker.erl @@ -158,7 +158,9 @@ simple_async_query(Id, Request, QueryOpts0) -> Ref = make_request_ref(), Result = call_query(async_if_possible, Id, Index, Ref, ?SIMPLE_QUERY(Request), QueryOpts), _ = handle_query_result(Id, Result, _HasBeenSent = false), - Result. + maybe_apply_async_reply_fun( + Result, QueryOpts + ). simple_query_opts() -> ensure_expire_at(#{simple_query => true, timeout => infinity}).