anchor.diff:  code_change(_OldVn, RMgr, _Extra) -> {ok, RMgr}.
   handle_cast(_Msg, RMgr) -> {noreply, RMgr}.
   
  -handle_call({replicate, [Addr] = Addrs, Out, Cmd, CmdArgs,
  -             ResponseFilter, ResponseModule, _Policy} = Request,
  +handle_call({replicate, Addrs, _Out, _Cmd, _CmdArgs,
  +             _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),
  +    % TODO: Use Policy.
  +    Replicator = create_replicator(Request, NotifyPid, undefined, Addrs),
  +    Replicator2 = send_cycle(Replicator),
  +    Replicators2 = dict:store(Replicator2#replicator.id,
  +                              Replicator2,
  +                              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
  -    % request/response.
  +    % Invoked when a downstream is done with a request/response.
       case dict:find(Id, Replicators) of
           {ok, #replicator{notify_pid = NotifyPid,
                            notify_data = NotifyData}} ->
  
positive.code: 
  notify(P, D, V) when is_pid(P) -> P ! {D, V};
  notify(_, _, _)                -> ok.
  
negative.code: 
  handle_info({'DOWN', Monitor, _, _, _} = Msg,
              #rmgr{curr = Replicators} = RMgr) ->
      % Invoked when a monitored downstream has died.
      Replicators2 =
          dict:filter(fun (_Id, #replicator{notify_pid = NotifyPid,
                                            notify_data = NotifyData,
  