diff options
Diffstat (limited to 'src/fabric/src/fabric_view_all_docs.erl')
| -rw-r--r-- | src/fabric/src/fabric_view_all_docs.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/fabric/src/fabric_view_all_docs.erl b/src/fabric/src/fabric_view_all_docs.erl index 30c8e8d51..a404125fa 100644 --- a/src/fabric/src/fabric_view_all_docs.erl +++ b/src/fabric/src/fabric_view_all_docs.erl @@ -26,12 +26,12 @@ go(DbName, Options, #mrargs{keys=undefined} = QueryArgs, Callback, Acc) -> Shards, fabric_rpc, all_docs, [Options, QueryArgs]), RexiMon = fabric_util:create_monitors(Workers0), try - case fabric_util:stream_start(Workers0, #shard.ref) of + case fabric_streams:start(Workers0, #shard.ref) of {ok, Workers} -> try go(DbName, Options, Workers, QueryArgs, Callback, Acc) after - fabric_util:cleanup(Workers) + fabric_streams:cleanup(Workers) end; {timeout, NewState} -> DefunctWorkers = fabric_util:remove_done_workers( |