anchor.diff:          {json_req, null},
           Db
       ),
  -    ChangesFeedFun({fun ?MODULE:changes_reader_cb/3, {Server, DbName}}).
  -
  -changes_reader_cb({change, Change, _}, _, {Server, DbName}) ->
  +    ChangesFeedFun({fun ?MODULE:changes_reader_cb/3, {Server, DbName, Epoch}}).
  +
  +changes_reader_cb({change, Change, _}, _, {Server, DbName, Epoch}) ->
       case has_valid_rep_id(Change) of
           true ->
               Msg = {rep_db_update, DbName, Change},
  
positive.code:         false ->
              ok
      end,
      {Server, DbName};
  changes_reader_cb({stop, EndSeq, _Pending}, _, {Server, DbName}) ->
      Msg = {rep_db_checkpoint, DbName, EndSeq},
      ok = gen_server:call(Server, Msg, infinity),
      {Server, DbName};
  changes_reader_cb(_, _, Acc) ->
      Acc.
  
  
negative.code:             end,
              true = ets:insert(?DB_TO_SEQ, {DbName, Since, false}),
              ensure_rep_ddoc_exists(DbName),
              Pid = start_changes_reader(DbName, Since, State#state.epoch),
              couch_log:debug("Scanning ~s from update_seq ~p", [DbName, Since]),
              [{DbName, Pid} | Pids]
      end,
  