anchor.diff:          qs = [{limit, 1000}, {startkey, StartSeq}]
       },
       {Results} = couch_rep_httpc:request(Req),
  -    if Results =:= [] -> exit(normal); true -> ok end,
  +    Rows = proplists:get_value(<<"rows">>, Results),
  +    if Rows =:= [] -> exit(normal); true -> ok end,
       EndSeq = lists:foldl(fun({RowInfoList}, _) ->
           Id = proplists:get_value(<<"id">>, RowInfoList),
           Seq = proplists:get_value(<<"key">>, RowInfoList),
  
positive.code:     last_seq,
      conn = nil,
      reqid = nil,
      by_seq_from = nil,
      by_seq_loop = nil,
      complete = false,
      count = 0,
      partial_chunk = nil,
  
negative.code:         ParsedRevs = couch_doc:parse_revs(lists:flatten(RawRevs)),
          Change = {[
              {<<"seq">>, Seq},
              {<<"id">>, Id},
              {<<"changes">>, [{[{<<"rev">>,R}]} || R <- ParsedRevs]}
          ]},
          gen_server:call(Server, {add_change, Change}),
          Seq
      end, 0, Rows),
      by_seq_loop(Server, Source, EndSeq+1).
  
  decode_row(<<",\n", Rest/binary>>) ->
  