anchor.diff:                      TimeoutFun
                   );
               _Else ->
  -                end_sending_changes(Callback, EndSeq, ResponseType)
  +                end_sending_changes(Callback, UserAcc2, EndSeq, ResponseType)
               end;
  -        stop ->
  +        {stop, UserAcc3} ->
               % ?LOG_INFO("wait_db_updated stop ~p",[{Db#db.name, EndSeq}]),
  -            end_sending_changes(Callback, EndSeq, ResponseType)
  +            end_sending_changes(Callback, UserAcc3, EndSeq, ResponseType)
           end
       end.
   
  -end_sending_changes(Callback, EndSeq, ResponseType) ->
  -    Callback({stop, EndSeq}, ResponseType).
  -
  -changes_enumerator(DocInfo, {Db, _, _, FilterFun, Callback, "continuous",
  -    Limit, IncludeDocs}) ->
  +end_sending_changes(Callback, UserAcc, EndSeq, ResponseType) ->
  +    Callback({stop, EndSeq}, ResponseType, UserAcc).
  +
  +changes_enumerator(DocInfo, {Db, _, _, FilterFun, Callback, UserAcc,
  +    "continuous", Limit, IncludeDocs}) ->
   
       #doc_info{id=Id, high_seq=Seq,
               revs=[#rev_info{deleted=Del,rev=Rev}|_]} = DocInfo,
  
positive.code:                 )
              after
                  couch_db_update_notifier:stop(Notify),
                  get_rest_db_updated() % clean out any remaining update messages
              end
          end;
      true ->
          fun(Callback) ->
              start_sending_changes(Callback, Args#changes_args.feed),
              {ok, {_, LastSeq, _Prepend, _, _, _, _, _}} =
                  send_changes(
                      Args#changes_args{feed="normal"},
                      Callback,
                      Db,
                      StartSeq,
                      <<"">>
                  ),
              end_sending_changes(Callback, LastSeq, Args#changes_args.feed)
          end
      end.
  
  %% @type Req -> #httpd{} | {json_req, JsonObj()}
  make_filter_fun(FilterName, Style, Req, Db) ->
  
negative.code:                     ok
                  end
              ),
              UserAcc2 = start_sending_changes(Callback, UserAcc, Feed),
              {Timeout, TimeoutFun} = get_changes_timeout(Args, Callback),
              try
                  keep_sending_changes(
                      Args,
                      Callback,
                      UserAcc2,
                      Db,
                      StartSeq,
                      <<"">>,
  