anchor.diff:              {ok, _} = save_doc(Db, {[{<<"_id">>, <<"doc12">>}]}),
               {ok, Rev3_3} = save_doc(Db, {[{<<"_id">>, <<"doc3">>},
                                             {<<"_rev">>, Rev3_2}]}),
  +            reset_row_notifications(),
               ok = unpause(Consumer),
  -            timer:sleep(100),
  +            ?assertEqual(ok, wait_row_notifications(2)),
               ok = pause(Consumer),
   
               NewRows = get_rows(Consumer),
  
positive.code:             GteDoc8 = {[{<<"$gte">>, <<"doc8">>}]},
              Selector = {[{<<"_id">>, GteDoc8}]},
              Req = {json_req, {[{<<"selector">>, Selector}]}},
              Consumer = spawn_consumer(DbName, ChArgs, Req),
              ok = pause(Consumer),
              Rows = get_rows(Consumer),
              ?assertMatch(
  
negative.code:                                      {<<"_rev">>, Rev8}]}),
              {ok, _} = save_doc(Db, {[{<<"_id">>, <<"doc4">>},
                                       {<<"_rev">>, Rev4}]}),
              reset_row_notifications(),
              ok = unpause(Consumer),
              ?assertEqual(ok, wait_row_notifications(1)),
              ok = pause(Consumer),
              NewRows = get_rows(Consumer),
              ?assertMatch(
  