We read every piece of feedback, and take your input very seriously.
To see all available qualifiers, see our documentation.
There was an error while loading. Please reload this page.
1 parent df25c13 commit f10b71cCopy full SHA for f10b71c
src/gm.erl
@@ -1559,9 +1559,10 @@ has_pending_messages(#state{ broadcast_buffer = Buffer })
1559
when Buffer =/= [] ->
1560
true;
1561
has_pending_messages(#state{ members_state = MembersState }) ->
1562
- [] =/= [M || {_, #member{last_pub = LP, last_ack = LA} = M}
1563
- <- MembersState,
1564
- LP =/= LA].
+ MembersWithPubAckMismatches = maps:filter(fun(_Id, #member{last_pub = LP, last_ack = LA}) ->
+ LP =/= LA
+ end, MembersState),
1565
+ 0 =/= maps:size(MembersWithPubAckMismatches).
1566
1567
maybe_confirm(_Self, _Id, Confirms, []) ->
1568
Confirms;
0 commit comments