diff options
| author | Adam Kocoloski <adam@cloudant.com> | 2010-09-06 18:10:16 -0700 |
|---|---|---|
| committer | Adam Kocoloski <adam@cloudant.com> | 2010-09-06 22:36:45 -0700 |
| commit | b8b2a9de28f4e74864f69e7681088d871e71820f (patch) | |
| tree | 00f2a686de5b17f52b6004f6b3fb17073073680e /apps/fabric/src/fabric_rpc.erl | |
| parent | a55c40ce30d5279df93b5c475cc6718575a1e192 (diff) | |
support for filtered _changes on multi-node clusters, closes #5
Diffstat (limited to 'apps/fabric/src/fabric_rpc.erl')
| -rw-r--r-- | apps/fabric/src/fabric_rpc.erl | 4 |
1 files changed, 2 insertions, 2 deletions
diff --git a/apps/fabric/src/fabric_rpc.erl b/apps/fabric/src/fabric_rpc.erl index 301fd46b..a7d555e0 100644 --- a/apps/fabric/src/fabric_rpc.erl +++ b/apps/fabric/src/fabric_rpc.erl @@ -338,10 +338,10 @@ send(Key, Value, #view_acc{limit=Limit} = Acc) -> end. changes_enumerator(DocInfo, {Db, _Seq, Args}) -> - #changes_args{include_docs=IncludeDocs, filter=FilterFun} = Args, + #changes_args{include_docs=IncludeDocs, filter=Acc} = Args, #doc_info{id=Id, high_seq=Seq, revs=[#rev_info{deleted=Del,rev=Rev}|_]} = DocInfo, - case [Result || Result <- FilterFun(DocInfo), Result /= null] of + case [X || X <- couch_changes:filter(DocInfo, Acc), X /= null] of [] -> {ok, {Db, Seq, Args}}; Results -> |