anchor.diff:      [] ->
           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).
  
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: 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),
  