Skip to content

Commit a751df9

Browse files
committed
wip
1 parent 1b973d2 commit a751df9

File tree

1 file changed

+3
-4
lines changed

1 file changed

+3
-4
lines changed

deps/rabbit/src/rabbit_fifo.erl

Lines changed: 3 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -3021,10 +3021,9 @@ incr_msg(Msg0, DelFailed, Anns) ->
30213021
end.
30223022

30233023
exec_read(Flru0, ReadPlan, Msgs) ->
3024-
{Entries, Flru} = ra:execute_read_plan(ReadPlan, Flru0),
3025-
%% pretend entries is a map
3024+
{Entries, Flru} = ra_log_read_plan:execute(ReadPlan, Flru0),
3025+
%% return a list in original order
30263026
{lists:map(fun ({MsgId, ?MSG(Idx, Header)}) ->
3027-
{_, _, Cmd, _} = maps:get(Idx, Entries),
3028-
%% hacky
3027+
Cmd = maps:get(Idx, Entries),
30293028
{MsgId, {Header, get_msg(Cmd)}}
30303029
end, Msgs), Flru}.

0 commit comments

Comments
 (0)