anchor.diff:  -record(replicator, {
             id,
             request,
  -          monitors,
  +          monitors = [],
             notify_pid,
             notify_data,
             replica_addrs,
  
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,
  