anchor.diff:      count = 0,
       partial_chunk = <<>>,
       reply_to = nil,
  -    rows = queue:new()
  +    rows = queue:new(),
  +    doc_ids = nil
   }).
   
   -import(couch_util, [
  
positive.code:     handle_feed_completion(State);
  handle_messages([<<"{\"last_seq\":", _/binary>>], State) ->
      handle_feed_completion(State);
  handle_messages([Chunk|Rest], State) ->
      #state{
          count = Count,
          partial_chunk = Partial,
          rows = Rows
      } = State,
      NewState = try
          Row = {Props} = decode_row(<<Partial/binary, Chunk/binary>>),
          case State of
          #state{reply_to=nil} ->
              State#state{
                  count = Count+1,
                  last_seq = couch_util:get_value(<<"seq">>, Props),
                  partial_chunk = <<>>,
                  rows=queue:in(Row,Rows)
              };
          #state{count=0, reply_to=From}->
              gen_server:reply(From, [Row]),
  
negative.code:         ?LOG_INFO("source doesn't have _changes, trying _all_docs_by_seq", []),
          Self = self(),
          BySeqPid = spawn_link(fun() -> by_seq_loop(Self, Source, Since) end),
          {ok, State#state{changes_loop = BySeqPid}};
      {ibrowse_async_headers, ReqId, "405", _}  when Method =:= post ->
          {ReqId2, Req2} = req_no_builtin_doc_ids(Req, ReqId),
          receive
          {ibrowse_async_headers, ReqId2, "200", _} ->
              {ok, State#state{
                  conn = Req2#http_db.conn,
                  reqid = ReqId2,
                  init_args = [Parent, Req2, Since, PostProps]}};
          {ibrowse_async_headers, ReqId, Code, Hdrs}
              when Code =:= "301"; Code =:= "302"; Code =:= "303" ->
              {ReqId3, Req3} = redirect_req(Req2, Code, Hdrs),
              receive
              {ibrowse_async_headers, ReqId3, "200", _} ->
                  {ok, State#state{
                      conn = Req3#http_db.conn,
                      reqid = ReqId3,
                      init_args = [Parent, Req3, Since, PostProps]}}
              after 30000 ->
                  {stop, changes_timeout}
              end
          after 30000 ->
              {stop, changes_timeout}
          end;
      {ibrowse_async_headers, ReqId, Code, _} ->
          {stop, {changes_error_code, list_to_integer(Code)}}
      after 10000 ->
  