anchor.diff:  -define(REP_ID_TO_DOC_ID_MAP, rep_id_to_rep_doc_id).
   
   -record(state, {
  -    changes_feed_loop,
  -    changes_queue,
  -    changes_processor
  +    changes_feed_loop = nil,
  +    changes_queue = nil,
  +    changes_processor = nil,
  +    db_notifier = nil
   }).
   
   
  
positive.code:     {ok, Pid}.
  
  
  changes_processor(ChangesQueue) ->
      Pid = spawn_link(
          fun() ->
  
negative.code:     [] ->
          none
      end.
  
  stop_all_replications() ->
      ets:foldl(
          fun({_, RepId}, _) -> couch_rep:end_replication(RepId) end,
          ok,
          ?DOC_TO_REP_ID_MAP
      ),
      true = ets:delete_all_objects(?REP_ID_TO_DOC_ID_MAP),
      true = ets:delete_all_objects(?DOC_TO_REP_ID_MAP).
  