Include accumulator in timeout response, BugzID 11432
diff --git a/src/rexi_utils.erl b/src/rexi_utils.erl
index abee74f..bb2a4c1 100644
--- a/src/rexi_utils.erl
+++ b/src/rexi_utils.erl
@@ -29,7 +29,7 @@
process_message(RefList, Keypos, Fun, Acc0, TimeoutRef, PerMsgTO) ->
receive
{timeout, TimeoutRef} ->
- timeout;
+ {timeout, Acc0};
{Ref, Msg} ->
case lists:keyfind(Ref, Keypos, RefList) of
false ->
@@ -49,5 +49,5 @@
io:format("rexi_DOWN ~p ~p", [ServerPid, Reason]),
Fun(Msg, nil, Acc0)
after PerMsgTO ->
- timeout
+ {timeout, Acc0}
end.