anchor.diff:                                       {<<"_rev">>, Rev8}]}),
               {ok, _} = save_doc(Db, {[{<<"_id">>, <<"doc4">>},
                                        {<<"_rev">>, Rev4}]}),
  +            reset_row_notifications(),
               ok = unpause(Consumer),
  -            timer:sleep(100),
  +            ?assertEqual(ok, wait_row_notifications(1)),
               ok = pause(Consumer),
               NewRows = get_rows(Consumer),
               ?assertMatch(
  
positive.code:             {ok, _} = save_doc(Db, {[{<<"_id">>, <<"doc12">>}]}),
              {ok, Rev3_3} = save_doc(Db, {[{<<"_id">>, <<"doc3">>},
                                            {<<"_rev">>, Rev3_2}]}),
              ok = unpause(Consumer),
              timer:sleep(100),
              ok = pause(Consumer),
  
              NewRows = get_rows(Consumer),
  
negative.code:         ChangesArgs = case (ChangesArgs0#changes_args.timeout =:= undefined)
              andalso (ChangesArgs0#changes_args.heartbeat =:= undefined) of
              true ->
                  ChangesArgs0#changes_args{timeout = 1000, heartbeat = 100};
              false ->
                  ChangesArgs0
          end,
  