anchor.diff:              {noreply, RMgr#rmgr{curr = Replicators2}};
           error ->
               {noreply, RMgr}
  -    end.
  +    end;
   
  -% handle_info({'DOWN', _MonitorRef, _, _, _}) ->
  -%     todo.
  +handle_info({'DOWN', Monitor, _, _, _} = Msg,
  +            #rmgr{curr = Replicators} = RMgr) ->
  +    % Invoked when a downstream is signalling from to monitor'ing
  +    % that it died.
  +    Replicators2 =
  +        dict:filter(fun (_Id, #replicator{notify_pid = NotifyPid,
  +                                          notify_data = NotifyData,
  +                                          monitors = Monitors}) ->
  +                        case lists:member(Monitor, Monitors) of
  +                            true  -> notify(NotifyPid, NotifyData, Msg),
  +                                     true;
  +                            false -> false
  +                        end
  +                    end,
  +                    Replicators),
  +    {noreply, RMgr#rmgr{curr = Replicators2}}.
   
   notify(P, D, V) when is_pid(P) -> P ! {D, V};
   notify(_, _, _)                -> ok.
  
positive.code: -record(replicator, {
      id,
      request,
      notify_pid,
      notify_data,
      replica_addrs,
  
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
  