anchor.diff:                         after
                              riak_sock_pool:checkin(?CONN_POOL, Conn)
                          end end),
  -    receive_fold_results(Acc, 0),
  -    {reply, Acc, State}.
  +    FinalAcc = receive_fold_results(Folder, Acc),
  +    {reply, FinalAcc, State}.
   
   is_empty(State) ->
       Partition = to_binary(State#state.partition),
  
positive.code:     Me = self(),
      FoldCatRef = {fold_catalog, erlang:make_ref()},
      CatalogResultsPid = spawn_link(fun() ->
                                             fold_catalog_process(FoldCatRef, Me, Folder, Acc, 
                                                                  false, 0, 0, false) end),
      spawn_link(fun() ->
                         try
  
negative.code: %% for each result of a stream process, package the entry in the
  %%   form of an infamously shady put-embedded command and forward
  %%   to receive_fold_results process
  fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, IndexBin, FieldBin, TermBin) ->
      receive
          {stream, StreamRef, timeout} ->
              CatalogProcessPid ! {fold_stream, done, StreamRef};
  