anchor.diff:          current_through_seq = ThroughSeq, stats = Stats} = State) ->
       gen_server:reply(From, ok),
       {NewThroughSeq0, NewSeqsInProgress} = case SeqsInProgress of
  +    [] ->
  +        {Seq, []};
       [Seq | Rest] ->
           {Seq, Rest};
       [_ | _] ->
  
positive.code: 
  
  spawn_changes_reader(StartSeq, #httpdb{} = Db, ChangesQueue, Options) ->
      spawn_link(fun() ->
          put(last_seq, StartSeq),
          put(retries_left, Db#httpdb.retries),
          read_changes(StartSeq, Db#httpdb{retries = 0}, ChangesQueue, Options)
      end);
  spawn_changes_reader(StartSeq, Db, ChangesQueue, Options) ->
      spawn_link(fun() ->
          read_changes(StartSeq, Db, ChangesQueue, Options)
      end).
  
  read_changes(StartSeq, Db, ChangesQueue, Options) ->
      try
          couch_replicator_api_wrap:changes_since(Db, all_docs, StartSeq,
              fun(#doc_info{high_seq = Seq, id = Id} = DocInfo) ->
  
negative.code:                     " with since=~p", [couch_replicator_api_wrap:db_uri(Db), LastSeq]),
                  Db
              end,
              read_changes(Parent, LastSeq, Db2, ChangesQueue, Options, Ts);
          _ ->
              exit(Error)
          end
  