anchor.diff:  has_valid_rep_id(_Else) ->
       true.
   
  +process_change(stop_all_replications) ->
  +    ?LOG_INFO("Stopping all ongoing replications because the replicator DB "
  +        "was deleted or changed", []),
  +    stop_all_replications();
   
   process_change({Change}) ->
       {RepProps} = JsonRepDoc = couch_util:get_value(doc, Change),
  
positive.code: -define(REP_ID_TO_DOC_ID_MAP, rep_id_to_rep_doc_id).
  
  -record(state, {
      changes_feed_loop,
      changes_queue,
      changes_processor
  }).
  
  
  
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).
  