anchor.diff:              ChArgs = #changes_args{filter = "_selector"},
               Selector = {[{<<"_id">>, <<"nopers">>}]},
               Req = {json_req, {[{<<"selector">>, Selector}]}},
  -            Consumer = spawn_consumer(DbName, ChArgs, Req),
  -            {Rows, LastSeq} = wait_finished(Consumer),
  -            {ok, Db} = couch_db:open_int(DbName, []),
  -            UpSeq = couch_db:get_update_seq(Db),
  -            couch_db:close(Db),
  -            stop_consumer(Consumer),
  +            {Rows, LastSeq, UpSeq} = run_changes_query(DbName, ChArgs, Req),
               ?assertEqual(0, length(Rows)),
               ?assertEqual(UpSeq, LastSeq)
           end).
  
positive.code: should_filter_by_view({DbName, _}) ->
      ?_test(
          begin
              {ok, Db0} = couch_db:open_int(DbName, [?ADMIN_CTX]),
              DDocId = <<"_design/app">>,
              DDoc = couch_doc:from_json_obj({[
                  {<<"_id">>, DDocId},
  
negative.code:             ChArgs = #changes_args{filter = "_selector"},
              Selector = {[{<<"_id">>, <<"doc3">>}]},
              Req = {json_req, {[{<<"selector">>, Selector}]}},
              {Rows, LastSeq, _} = run_changes_query(DbName, ChArgs, Req),
              ?assertMatch(
                  [#row{seq = LastSeq, id = <<"doc3">>, deleted = true}],
                  Rows
  