anchor.diff:      end.
   
   changes_enumerator(DocInfos, {Db, _, _, FilterFun, Resp, "continuous", IncludeDocs}) ->
  -    [#doc_info{id=Id, high_seq=Seq, revs=[#rev_info{rev=#rev_info{deleted=Del}=Rev}|_]}|_] = DocInfos,
  +    [#doc_info{id=Id, high_seq=Seq, revs=[#rev_info{rev=Rev}|_]}|_] = DocInfos,
       Results0 = [FilterFun(DocInfo) || DocInfo <- DocInfos],
       Results = [Result || Result <- Results0, Result /= null],
       case Results of
       [] ->
           {ok, {Db, Seq, nil, FilterFun, Resp, "continuous", IncludeDocs}};
       _ ->
  -        send_chunk(Resp, [?JSON_ENCODE(changes_row(Db, Seq, Id, Del, Results, Rev, IncludeDocs))
  +        send_chunk(Resp, [?JSON_ENCODE(changes_row(Db, Seq, Id, Results, Rev, IncludeDocs))
               |"\n"]),
           {ok, {Db, Seq, nil, FilterFun, Resp, "continuous", IncludeDocs}}
       end;
   changes_enumerator(DocInfos, {Db, _, Prepend, FilterFun, Resp, _, IncludeDocs}) ->
  -    [#doc_info{id=Id, high_seq=Seq, revs=[#rev_info{rev=#rev_info{deleted=Del}=Rev}|_]}|_] = DocInfos,
  +    [#doc_info{id=Id, high_seq=Seq, revs=[#rev_info{rev=Rev}|_]}|_] = DocInfos,
       Results0 = [FilterFun(DocInfo) || DocInfo <- DocInfos],
       Results = [Result || Result <- Results0, Result /= null],
       case Results of
  
positive.code:         {ok, {Db, Seq, Prepend, FilterFun, Resp, nil, IncludeDocs}};
      _ ->
          send_chunk(Resp, [Prepend, ?JSON_ENCODE(
              changes_row(Db, Seq, Id, Del, Results, Rev, IncludeDocs))]),
          {ok, {Db, Seq, <<",\n">>, FilterFun, Resp, nil, IncludeDocs}}
      end.
  
  changes_row(Db, Seq, Id, Results, Rev, true) ->
      {[{seq,Seq},{id,Id},
          {changes,Results}] ++
          deleted_item(Del) ++
          couch_httpd_view:doc_member(Db, Id, Rev)};
  changes_row(_, Seq, Id, Results, _, false) ->
      {[{seq,Seq},{id,Id},
          {changes,Results}]}.
  
  deleted_item(true) -> [{deleted,true}];
  deleted_item(_) -> [].
  
  send_changes(Req, Resp, Db, Dir, StartSeq, Prepend, ResponseType, FilterFun, End) ->
      Style = list_to_existing_atom(
  
negative.code:             get_rest_db_updated() % clean out any remaining update messages
          end;
      true ->
          {ok, Info} = couch_db:get_db_info(Db),
          CurrentEtag = couch_httpd:make_etag(Info),
          couch_httpd:etag_respond(Req, CurrentEtag, fun() ->
              % send the etag
  