diff options
| author | Paul J. Davis <paul.joseph.davis@gmail.com> | 2019-05-20 13:01:29 -0500 |
|---|---|---|
| committer | Paul J. Davis <paul.joseph.davis@gmail.com> | 2019-05-20 13:01:29 -0500 |
| commit | b290ae4864d8ddae9427f1faf534048868d9d67d (patch) | |
| tree | 2e9dd521684f46957624927a1c61a9282b98fc2b | |
| parent | c5bd851668bda1c3b4c48c0e872a1a655b4abdee (diff) | |
| download | couchdb-b290ae4864d8ddae9427f1faf534048868d9d67d.tar.gz | |
Update API to pass options and handle empty since_seq
| -rw-r--r-- | src/fabric/src/fabric2_fdb.erl | 6 |
1 files changed, 3 insertions, 3 deletions
diff --git a/src/fabric/src/fabric2_fdb.erl b/src/fabric/src/fabric2_fdb.erl index e49f9be75..d57ad3ecd 100644 --- a/src/fabric/src/fabric2_fdb.erl +++ b/src/fabric/src/fabric2_fdb.erl @@ -599,7 +599,7 @@ fold_docs(#{} = Db, UserFun, UserAcc0, Options) -> {key, DocId}, {value, couch_doc:rev_to_str(RevId)} ]}, UserAccIn)) - end, UserAcc1, [{reverse, Reverse}]), + end, UserAcc1, [{reverse, Reverse}] ++ Options), {ok, maybe_stop(UserFun(Db, complete, UserAcc2))} catch throw:{stop, FinalUserAcc} -> @@ -659,7 +659,7 @@ fold_changes(#{} = Db, SinceSeq0, UserFun, UserAcc0, Options) -> {id, DocId}, {changes, [{[{rev, couch_doc:rev_to_str(RevId)}]}]} ] ++ DelMember}}, UserAccIn)) - end, UserAcc1, [{reverse, Reverse}]), + end, UserAcc1, [{reverse, Reverse}] ++ Options), UserFun(Db, {stop, get('$last_changes_seq'), null}, UserAcc2) catch throw:{stop, FinalUserAcc} -> @@ -906,7 +906,7 @@ get_dir_and_bounds(DbPrefix, Options) -> {Reverse, StartKey4, EndKey4}. -get_since_seq(Seq) when Seq == 0; Seq == <<"0">> -> +get_since_seq(Seq) when Seq == 0; Seq == <<"0">>; Seq == <<>> -> fabric2_util:seq_zero_vs(); get_since_seq(Seq) when Seq == now; Seq == <<"now">> -> |