anchor.diff:  should_filter_by_specific_doc_ids_with_since({DbName, _}) ->
       ?_test(
           begin
  -            ChangesArgs = #changes_args{
  +            ChArgs = #changes_args{
                   filter = "_doc_ids",
                   since = 5
               },
               DocIds = [<<"doc3">>, <<"doc4">>, <<"doc9999">>],
               Req = {json_req, {[{<<"doc_ids">>, DocIds}]}},
  -            Consumer = spawn_consumer(DbName, ChangesArgs, 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(1, length(Rows)),
               [#row{seq = Seq1, id = Id1}] = Rows,
  
positive.code: should_filter_by_fast_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: should_filter_by_specific_doc_ids_no_result({DbName, _}) ->
      ?_test(
          begin
              ChArgs = #changes_args{
                  filter = "_doc_ids",
                  since = 6
              },
              DocIds = [<<"doc3">>, <<"doc4">>, <<"doc9999">>],
              Req = {json_req, {[{<<"doc_ids">>, DocIds}]}},
              {Rows, LastSeq, UpSeq} = run_changes_query(DbName, ChArgs, Req),
  
              ?assertEqual(0, length(Rows)),
              ?assertEqual(UpSeq, LastSeq)
  