anchor.diff:               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 = mc_downstream:send(Addr, Out, Cmd, CmdArgs,
  -                               ResponseFilter, ResponseModule,
  -                               self(), Id),
  -    {reply, Reply, RMgr#rmgr{curr = Replicators2}}.
  +    {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
  
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: -record(replicator, {
      id,
      request,
      monitors,
      notify_pid,
      notify_data,
      replica_addrs,
  