anchor.diff:          db_open_options = DbOptions
       } = Args,
       % ?LOG_INFO("send_changes start ~p",[StartSeq]),
  -    {ok, {_, EndSeq, Prepend2, _, _, _, NewLimit, _}} = send_changes(
  -        Args#changes_args{dir=fwd}, Callback, Db, StartSeq, Prepend
  +    {ok, {_, EndSeq, Prepend2, _, _, UserAcc2, _, NewLimit, _}} = send_changes(
  +        Args#changes_args{dir=fwd}, Callback, UserAcc, Db, StartSeq, Prepend
       ),
       % ?LOG_INFO("send_changes last ~p",[EndSeq]),
       couch_db:close(Db),
       if Limit > NewLimit, ResponseType == "longpoll" ->
  -        end_sending_changes(Callback, EndSeq, ResponseType);
  +        end_sending_changes(Callback, UserAcc2, EndSeq, ResponseType);
       true ->
  -        case wait_db_updated(Timeout, TimeoutFun) of
  -        updated ->
  +        case wait_db_updated(Timeout, TimeoutFun, UserAcc2) of
  +        {updated, UserAcc3} ->
               % ?LOG_INFO("wait_db_updated updated ~p",[{Db#db.name, EndSeq}]),
               DbOptions1 = [{user_ctx, Db#db.user_ctx} | DbOptions],
               case couch_db:open(Db#db.name, DbOptions1) of
  
positive.code:                     TimeoutFun
                  );
              _Else ->
                  end_sending_changes(Callback, EndSeq, ResponseType)
              end;
          stop ->
              % ?LOG_INFO("wait_db_updated stop ~p",[{Db#db.name, EndSeq}]),
              end_sending_changes(Callback, EndSeq, ResponseType)
          end
      end.
  
  end_sending_changes(Callback, EndSeq, ResponseType) ->
      Callback({stop, EndSeq}, ResponseType).
  
  changes_enumerator(DocInfo, {Db, _, _, FilterFun, Callback, "continuous",
      Limit, IncludeDocs}) ->
  
      #doc_info{id=Id, high_seq=Seq,
              revs=[#rev_info{deleted=Del,rev=Rev}|_]} = DocInfo,
  
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,
                      <<"">>,
  