anchor.diff:  
   -record(acc, {
       parent,
  -    state
  +    state,
  +    shards
   }).
   
   go(Parent, ParentRef, DbName, Timeout) ->
  -    Notifiers = start_update_notifiers(DbName),
  +    Shards = mem3:shards(DbName),
  +    Notifiers = start_update_notifiers(Shards),
       MonRefs = lists:usort([rexi_utils:server_pid(N) || #worker{node = N} <- Notifiers]),
       RexiMon = rexi_monitor:start(MonRefs),
       MonPid = start_cleanup_monitor(self(), Notifiers),
  
positive.code:     {stop, ok}.
  
  
  
  
negative.code:     %% process to communicate via handle_message/3 we "fake" it as a
      %% a spawned worker.
      Workers = [#worker{ref=ParentRef, pid=Parent} | Notifiers],
      Acc = #acc{
          parent = Parent,
          state = unset,
          shards = Shards
      },
      Resp = try
          receive_results(Workers, Acc, Timeout)
      after
          rexi_monitor:stop(RexiMon),
          stop_cleanup_monitor(MonPid)
  