From e8183a96759ecd254fe0de386f5ad5c0bf5a99a6 Mon Sep 17 00:00:00 2001 From: chronolaw Date: Sun, 22 Dec 2024 11:29:07 +0800 Subject: [PATCH] typo fix --- kong/clustering/rpc/socket.lua | 4 +++- 1 file changed, 3 insertions(+), 1 deletion(-) diff --git a/kong/clustering/rpc/socket.lua b/kong/clustering/rpc/socket.lua index 8f9b86863e85..e5131769ec08 100644 --- a/kong/clustering/rpc/socket.lua +++ b/kong/clustering/rpc/socket.lua @@ -228,6 +228,8 @@ function _M:start() assert(typ == "binary") local payloads + local results = {} + local payload = decompress_payload(data) if isarray(payload) then @@ -241,7 +243,7 @@ function _M:start() end -- isarray for _, v in ipairs(payloads) do - local ok, err = self:process_rpc_msg(payload) + local ok, err = self:process_rpc_msg(v) if not ok then return nil, err end