Skip to content

Commit 18f60db

Browse files
michaelklishinmergify-bot
authored andcommitted
More #4217 feedback (cosmetics)
(cherry picked from commit 46662ec) (cherry picked from commit f1a0bd7)
1 parent 502ad15 commit 18f60db

File tree

1 file changed

+5
-4
lines changed

1 file changed

+5
-4
lines changed

deps/rabbit/src/rabbit_stream_coordinator.erl

Lines changed: 5 additions & 4 deletions
Original file line numberDiff line numberDiff line change
@@ -528,10 +528,11 @@ apply(Meta, {machine_version, From = 1, To = 2}, State = #?MODULE{streams = Stre
528528
%% transform the listeners of each stream and accumulate listener PIDs
529529
{Streams1, Listeners} =
530530
maps:fold(fun(S, #stream{listeners = L0} = S0, {StreamAcc, GlobalListAcc}) ->
531-
{L1, GlobalListAcc1} = maps:fold(fun(ListPid, LeaderPid, {LAcc, GLAcc}) ->
532-
{LAcc#{{ListPid, leader} => LeaderPid},
533-
GLAcc#{ListPid => S}}
534-
end, {#{}, GlobalListAcc}, L0),
531+
{L1, GlobalListAcc1} = maps:fold(
532+
fun(ListPid, LeaderPid, {LAcc, GLAcc}) ->
533+
{LAcc#{{ListPid, leader} => LeaderPid},
534+
GLAcc#{ListPid => S}}
535+
end, {#{}, GlobalListAcc}, L0),
535536
{StreamAcc#{S => S0#stream{listeners = L1}}, GlobalListAcc1}
536537
end, {#{}, #{}}, Streams0),
537538
%% accumulate monitors for the map and create the effects to emit the monitors

0 commit comments

Comments
 (0)