anchor.diff:  -include("riak_kv_js_pools.hrl").
   
   -record(state, {acc :: list(),
  +                inacc :: list(),
                   delay :: integer(),
                   delay_max :: integer(),
                   p :: riak_pipe_vnode:partition(),
  
positive.code: 
  %% @doc The archive is the accumulator.
  -spec archive(state()) -> {ok, list()}.
  archive(#state{acc=Acc}) ->
      %% just send state of reduce so far
      {ok, Acc}.
  
  %% @doc Handoff simply concatenates the accumulator from the remote
  %% worker with the accumulator from this worker, and immediately
  
negative.code: 
  -spec handoff_acc([term()], [term()], state()) -> [term()].
  handoff_acc(HandoffAcc, LocalAcc, State) ->
      InAcc = LocalAcc++HandoffAcc,
      reduce(InAcc, State, "reducing handoff").
  
  %% @doc Actually evaluate the aggregation function.
  