diff options
Diffstat (limited to 'src/fabric/src/fabric_view_changes.erl')
| -rw-r--r-- | src/fabric/src/fabric_view_changes.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/src/fabric/src/fabric_view_changes.erl b/src/fabric/src/fabric_view_changes.erl index 7288f1aa5..f96bb058d 100644 --- a/src/fabric/src/fabric_view_changes.erl +++ b/src/fabric/src/fabric_view_changes.erl @@ -166,7 +166,7 @@ send_changes(DbName, ChangesArgs, Callback, PackedSeqs, AccIn, Timeout) -> end, RexiMon = fabric_util:create_monitors(Workers0), try - case fabric_util:stream_start(Workers0, #shard.ref, StartFun, Repls) of + case fabric_streams:start(Workers0, #shard.ref, StartFun, Repls) of {ok, Workers} -> try LiveSeqs = lists:map(fun(W) -> @@ -178,7 +178,7 @@ send_changes(DbName, ChangesArgs, Callback, PackedSeqs, AccIn, Timeout) -> send_changes(DbName, Workers, LiveSeqs, ChangesArgs, Callback, AccIn, Timeout) after - fabric_util:cleanup(Workers) + fabric_streams:cleanup(Workers) end; {timeout, NewState} -> DefunctWorkers = fabric_util:remove_done_workers( |