From 5425f3d88e1efa0112fa791a80080480ea9edf9d Mon Sep 17 00:00:00 2001 From: Thales Macedo Garitezi Date: Fri, 13 Jan 2023 17:33:57 -0300 Subject: [PATCH] refactor: rm unused fn --- apps/emqx_resource/src/emqx_resource_worker.erl | 10 ---------- 1 file changed, 10 deletions(-) diff --git a/apps/emqx_resource/src/emqx_resource_worker.erl b/apps/emqx_resource/src/emqx_resource_worker.erl index eafe7cea6..d681c82c3 100644 --- a/apps/emqx_resource/src/emqx_resource_worker.erl +++ b/apps/emqx_resource/src/emqx_resource_worker.erl @@ -761,16 +761,6 @@ batch_reply_after_query(Pid, Id, Index, InflightTID, Ref, Batch, Result) -> ok end. -ack_inflight_and_resume(Pid, InflightTID, Ref, Id, Index) -> - IsAcked = ack_inflight(InflightTID, Ref, Id, Index), - case is_inflight_full(InflightTID) of - true -> - ok; - false -> - ?MODULE:resume(Pid) - end, - IsAcked. - %%============================================================================== %% operations for queue queue_item_marshaller(Bin) when is_binary(Bin) ->