anchor.diff:          bufsize = Size + Len
       },
       {ok, Acc}.
  -
  -is_old_couch(Resp) ->
  -    MochiReq = chttpd:get_delayed_req(Resp),
  -    case MochiReq:get_header_value("user-agent") of
  -    undefined ->
  -        false;
  -    "CouchDB/1.0.0" ->
  -        true;
  -    UserAgent ->
  -        string:str(UserAgent, "CouchDB/0") > 0
  -    end.
   
   handle_compact_req(Req, _) ->
       Msg = <<"Compaction must be triggered on a per-shard basis in CouchDB">>,
  
positive.code:     Data = [?JSON_ENCODE(Change) | "\n"],
      Len = iolist_size(Data),
      maybe_flush_changes_feed(Acc, Data, Len);
  changes_callback({stop, EndSeq0, Pending}, #cacc{feed = continuous} = Acc) ->
      #cacc{mochi = Resp, buffer = Buf} = Acc,
      EndSeq = case is_old_couch(Resp) of true -> 0; false -> EndSeq0 end,
      Row = {[
          {<<"last_seq">>, EndSeq},
          {<<"pending">>, Pending}
  
negative.code:     maybe_flush_changes_feed(Acc, Data, Len);
  changes_callback({stop, EndSeq, Pending}, Acc) ->
      #cacc{buffer = Buf, mochi = Resp} = Acc,
      {ok, Resp1} = chttpd:send_delayed_chunk(Resp, [
              Buf,
              "\n],\n\"last_seq\":",
              ?JSON_ENCODE(EndSeq),
  