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