anchor.diff:                      " with since=~p", [couch_replicator_api_wrap:db_uri(Db), LastSeq]),
                   Db
               end,
  -            read_changes(LastSeq, Db2, ChangesQueue, Options);
  +            read_changes(Parent, LastSeq, Db2, ChangesQueue, Options, Ts);
           _ ->
               exit(Error)
           end
  
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:         current_through_seq = ThroughSeq, stats = Stats} = State) ->
      gen_server:reply(From, ok),
      {NewThroughSeq0, NewSeqsInProgress} = case SeqsInProgress of
      [] ->
          {Seq, []};
      [Seq | Rest] ->
          {Seq, Rest};
      [_ | _] ->
  