From dc7953c3e10e1c0dc792389fd15c45300ad4b764 Mon Sep 17 00:00:00 2001
From: JimMoen <LnJimMoen@outlook.com>
Date: Fri, 12 Aug 2022 17:28:56 +0800
Subject: [PATCH] chore: refine async query variable name

---
 apps/emqx_connector/src/emqx_connector_http.erl | 8 ++++----
 1 file changed, 4 insertions(+), 4 deletions(-)

diff --git a/apps/emqx_connector/src/emqx_connector_http.erl b/apps/emqx_connector/src/emqx_connector_http.erl
index 11030fef6..b7fd21c5f 100644
--- a/apps/emqx_connector/src/emqx_connector_http.erl
+++ b/apps/emqx_connector/src/emqx_connector_http.erl
@@ -304,7 +304,7 @@ on_query(
     end,
     Result.
 
-on_query_async(InstId, {send_message, Msg}, ReplyFun, State) ->
+on_query_async(InstId, {send_message, Msg}, ReplyFunAndArgs, State) ->
     case maps:get(request, State, undefined) of
         undefined ->
             ?SLOG(error, #{msg => "arg_request_not_found", connector => InstId}),
@@ -320,14 +320,14 @@ on_query_async(InstId, {send_message, Msg}, ReplyFun, State) ->
             on_query_async(
                 InstId,
                 {undefined, Method, {Path, Headers, Body}, Timeout},
-                ReplyFun,
+                ReplyFunAndArgs,
                 State
             )
     end;
 on_query_async(
     InstId,
     {KeyOrNum, Method, Request, Timeout},
-    ReplyFun,
+    ReplyFunAndArgs,
     #{pool_name := PoolName, base_path := BasePath} = State
 ) ->
     ?TRACE(
@@ -346,7 +346,7 @@ on_query_async(
         Method,
         NRequest,
         Timeout,
-        ReplyFun
+        ReplyFunAndArgs
     ).
 
 on_get_status(_InstId, #{pool_name := PoolName, connect_timeout := Timeout} = State) ->