summaryrefslogtreecommitdiff
path: root/src/fabric_view_all_docs.erl
diff options
context:
space:
mode:
Diffstat (limited to 'src/fabric_view_all_docs.erl')
-rw-r--r--src/fabric_view_all_docs.erl10
1 files changed, 0 insertions, 10 deletions
diff --git a/src/fabric_view_all_docs.erl b/src/fabric_view_all_docs.erl
index 99834286..196d6837 100644
--- a/src/fabric_view_all_docs.erl
+++ b/src/fabric_view_all_docs.erl
@@ -19,7 +19,6 @@ go(DbName, #view_query_args{keys=nil} = QueryArgs, Callback, Acc0) ->
counters = fabric_dict:init(Workers, 0),
skip = Skip,
limit = Limit,
- stop_fun = stop_fun(QueryArgs),
user_acc = Acc0
},
try fabric_util:receive_loop(Workers, #shard.ref, fun handle_message/3,
@@ -120,15 +119,6 @@ handle_message(complete, Worker, State) ->
fabric_view:maybe_send_row(State#collector{counters = Counters}).
-stop_fun(#view_query_args{direction=fwd, end_key=EndKey}) ->
- fun(#view_row{id=Id}) ->
- couch_db_updater:less_docid(EndKey, Id)
- end;
-stop_fun(#view_query_args{direction=rev, end_key=EndKey}) ->
- fun(#view_row{id=Id}) ->
- couch_db_updater:less_docid(Id, EndKey)
- end.
-
merge_row(fwd, Row, Rows) ->
lists:keymerge(#view_row.id, [Row], Rows);
merge_row(rev, Row, Rows) ->