summaryrefslogtreecommitdiff
path: root/apps/fabric/src/fabric_view_reduce.erl
diff options
context:
space:
mode:
Diffstat (limited to 'apps/fabric/src/fabric_view_reduce.erl')
-rw-r--r--apps/fabric/src/fabric_view_reduce.erl2
1 files changed, 1 insertions, 1 deletions
diff --git a/apps/fabric/src/fabric_view_reduce.erl b/apps/fabric/src/fabric_view_reduce.erl
index f401fc58..6ae564cc 100644
--- a/apps/fabric/src/fabric_view_reduce.erl
+++ b/apps/fabric/src/fabric_view_reduce.erl
@@ -49,7 +49,7 @@ go(DbName, DDoc, VName, Args, Callback, Acc0) ->
rows = dict:new(),
user_acc = Acc0
},
- try fabric_util:receive_loop(Workers, #shard.ref, fun handle_message/3,
+ try rexi_utils:recv(Workers, #shard.ref, fun handle_message/3,
State, infinity, 1000 * 60 * 60) of
{ok, NewState} ->
{ok, NewState#collector.user_acc};