anchor.diff:  -record(replicator, {
       id,
       request,
  +    monitors,
       notify_pid,
       notify_data,
       replica_addrs,
  
positive.code:             {noreply, RMgr#rmgr{curr = Replicators2}};
          error ->
              {noreply, RMgr}
      end.
  
  % handle_info({'DOWN', _MonitorRef, _, _, _}) ->
  %     todo.
  
  notify(P, D, V) when is_pid(P) -> P ! {D, V};
  notify(_, _, _)                -> ok.
  
negative.code:              ResponseFilter, ResponseModule, _Policy} = Request,
              {NotifyPid, _}, #rmgr{curr = Replicators} = RMgr) ->
      Id = make_ref(),
      {ok, Monitors} = mc_downstream:send(Addr, Out, Cmd, CmdArgs,
                                          ResponseFilter, ResponseModule,
                                          self(), Id),
      Replicator =
          #replicator{id = Id,
                      request = Request,
                      monitors = Monitors,
                      notify_pid = NotifyPid,
                      notify_data = undefined,
                      replica_addrs = Addrs,
                      replica_min = 1},
      Replicators2 = dict:store(Id, Replicator, Replicators),
      {reply, {ok, []}, RMgr#rmgr{curr = Replicators2}}.
  
  handle_info({Id, RV}, #rmgr{curr = Replicators} = RMgr) ->
      % Invoked when a downstream is signalling that it's done with a
  