anchor.diff:      Go = if Limit =< 1 -> stop; true -> ok end,
       case Results of
       [] ->
  -        {Go, {Db, Seq, nil, FilterFun, Callback, "continuous", Limit,
  +        {Go, {Db, Seq, nil, FilterFun, Callback, UserAcc, "continuous", Limit,
                   IncludeDocs}
           };
       _ ->
           ChangesRow = changes_row(Db, Seq, Id, Del, Results, Rev, IncludeDocs),
  -        Callback({change, ChangesRow, <<"">>}, "continuous"),
  -        {Go, {Db, Seq, nil, FilterFun, Callback, "continuous",  Limit - 1,
  -                IncludeDocs}
  +        UserAcc2 = Callback({change, ChangesRow, <<>>}, "continuous", UserAcc),
  +        {Go, {Db, Seq, nil, FilterFun, Callback, UserAcc2, "continuous",
  +                Limit - 1, IncludeDocs}
           }
       end;
  -changes_enumerator(DocInfo, {Db, _, Prepend, FilterFun, Callback, ResponseType,
  -    Limit, IncludeDocs}) ->
  +changes_enumerator(DocInfo, {Db, _, Prepend, FilterFun, Callback, UserAcc,
  +    ResponseType, Limit, IncludeDocs}) ->
   
       #doc_info{id=Id, high_seq=Seq, revs=[#rev_info{deleted=Del,rev=Rev}|_]}
           = DocInfo,
  
positive.code:         StartSeq,
          fun changes_enumerator/2,
          [{dir, Dir}],
          {Db, StartSeq, Prepend, FilterFun, Callback, ResponseType, Limit,
              IncludeDocs}
      ).
  
  keep_sending_changes(Args, Callback, Db, StartSeq, Prepend, Timeout,
      TimeoutFun) ->
      #changes_args{
          feed = ResponseType,
  
negative.code: 
  %% @type Req -> #httpd{} | {json_req, JsonObj()}
  handle_changes(#changes_args{style=Style}=Args1, Req, Db) ->
      #changes_args{feed = Feed} = Args = Args1#changes_args{
          filter = make_filter_fun(Args1#changes_args.filter, Style, Req, Db)
      },
      StartSeq = case Args#changes_args.dir of
      rev ->
          couch_db:get_update_seq(Db);
      fwd ->
          Args#changes_args.since
      end,
      if Feed == "continuous" orelse Feed == "longpoll" ->
          fun(CallbackAcc) ->
              {Callback, UserAcc} = get_callback_acc(CallbackAcc),
              Self = self(),
              {ok, Notify} = couch_db_update_notifier:start_link(
                  fun({_, DbName}) when DbName == Db#db.name ->
  