chore: address review comments

kafka4beam · Oct 9, 2024 · a67da3b · a67da3b
1 parent 9347ec1
commit a67da3b
Show file tree

Hide file tree

Showing 2 changed files with 3 additions and 3 deletions.
diff --git a/src/wolff_pendack.erl b/src/wolff_pendack.erl
@@ -133,7 +133,7 @@ drop1(#{backlog := Cbs0, count := Count} = X, [Id | Ids], Acc) ->
         false ->
             drop1(X, Ids, Acc);
         {ok, Cb, Cbs}  ->
-            drop1(X#{backlog => Cbs, count => Count - 1}, Ids, [Cb | Acc])
+            drop1(X#{backlog := Cbs, count := Count - 1}, Ids, [Cb | Acc])
     end.
 
 %% @doc Move a list of calls from the head of the backlog queue
@@ -150,5 +150,5 @@ move1(#{backlog := Backlog0, inflight := Inflight0} = X, Id) ->
             X;
         {ok, Cb, Backlog} ->
             Inflight = insert_cb(Inflight0, Id, Cb),
-           X#{backlog => Backlog, inflight => Inflight}
+           X#{backlog := Backlog, inflight := Inflight}
     end.
diff --git a/test/wolff_tests.erl b/test/wolff_tests.erl
@@ -331,7 +331,7 @@ replayq_overflow_while_inflight_test() ->
   Pid = wolff_producers:lookup_producer(Producers, 0),
   ?assert(is_process_alive(Pid)),
   TesterPid = self(),
-  ok = meck:new(kpro, [non_strict, no_history, no_link, passthrough]),
+  ok = meck:new(kpro, [no_history, no_link, passthrough]),
   meck:expect(kpro, send,
               fun(_Conn, Req) ->
                       Payload = iolist_to_binary(lists:last(tuple_to_list(Req))),