| a | b | |
|---|
| 0 | + | diff --git a/src/couch_replicator/src/couch_replicator_api_wrap.erl b/src/couch_replicator/src/couch_replicator_api_wrap.erl |
|---|
| 0 | + | index 42f393e..b20ff72 100644 |
|---|
| 0 | + | --- a/src/couch_replicator/src/couch_replicator_api_wrap.erl |
|---|
| 0 | + | +++ b/src/couch_replicator/src/couch_replicator_api_wrap.erl |
|---|
| 0 | + | @@ -314,7 +314,7 @@ changes_since(#httpdb{headers = Headers1} = HttpDb, Style, StartSeq, |
|---|
| 0 | + | true -> |
|---|
| 0 | + | [{"feed", "continuous"}] |
|---|
| 0 | + | end ++ [ |
|---|
| 0 | + | - {"style", atom_to_list(Style)}, {"since", couch_util:to_list(StartSeq)}, |
|---|
| 0 | + | + {"style", atom_to_list(Style)}, {"since", seq_to_string(StartSeq)}, |
|---|
| 0 | + | {"heartbeat", integer_to_list(HeartBeat)} |
|---|
| 0 | + | ], |
|---|
| 0 | + | DocIds = get_value(doc_ids, Options), |
|---|
| 0 | + | @@ -383,6 +383,12 @@ changes_since(Db, Style, StartSeq, UserFun, Options) -> |
|---|
| 0 | + | |
|---|
| 0 | + | % internal functions |
|---|
| 0 | + | |
|---|
| 0 | + | +seq_to_string([Num, Bin]) when is_integer(Num), is_binary(Bin) -> |
|---|
| 0 | + | + % BigCouch |
|---|
| 0 | + | + integer_to_list(Num) ++ "-" ++ ?b2l(Bin); |
|---|
| 0 | + | +seq_to_string(Seq) -> |
|---|
| 0 | + | + couch_util:to_list(Seq). |
|---|
| 0 | + | + |
|---|
| 0 | + | maybe_add_changes_filter_q_args(BaseQS, Options) -> |
|---|
| 0 | + | case get_value(filter, Options) of |
|---|
| 0 | + | undefined -> |
|---|
| ... | |
|---|