anchor.diff:      % Automatically start node local changes feed loop
       LocalRepDb = ?l2b(config:get("replicator", "db", "_replicator")),
       ensure_rep_db_exists(LocalRepDb),
  -    Pid = changes_feed_loop(LocalRepDb, 0),
  +    Pid = start_changes_reader(LocalRepDb, 0),
       {ok, #state{
           event_listener = start_event_listener(),
           scan_pid = ScanPid,
  
positive.code: % gen_server callbacks
  -export([start_link/0, init/1, handle_call/3, handle_info/2, handle_cast/2]).
  -export([code_change/3, terminate/2]).
  
  % config_listener callback
  -export([handle_config_change/5]).
  
negative.code:         [{DbName, EndSeq}] -> EndSeq
      end,
      ensure_rep_ddoc_exists(DbName),
      Pid = start_changes_reader(DbName, Since),
      couch_log:debug("Scanning ~s from update_seq ~p", [DbName, Since]),
      {noreply, State#state{rep_start_pids = [Pid | State#state.rep_start_pids]}};
  
  