anchor.diff:  fold(Folder, Acc, State) ->
   %% spawn a process to kick off the catalog listing
   %%   for the this partition, e.g.,
  -    io:format("fold(~p, ~p, ~p)~n", [State, Folder, Acc]),
  -    io:format("fold/sync...~n"),
  +    %% io:format("fold(~p, ~p, ~p)~n", [State, Folder, Acc]),
  +    %% io:format("fold/sync...~n"),
       sync(),
  -    io:format("fold/sync complete.~n"),
  +    %% io:format("fold/sync complete.~n"),
       Partition = integer_to_list(State#state.partition),
       {ok, Conn} = raptor_conn_pool:checkout(),
       Me = self(),
  
positive.code:                     skip
              end,
              receive_stream_results(StreamRef, Sender, FilterFun, Acc2);
          Msg ->
              %% TODO: Should this throw - must be an error
              io:format("receive_stream_results(~p, ~p, ~p) -> ~p~n",
                  [StreamRef, Sender, FilterFun, Msg]),
              riak_search_backend:stream_response_done(Sender)
      end,
      ok.
  
negative.code:         {stream, StreamRef, timeout} ->
              CatalogProcessPid ! {fold_stream, done, StreamRef};
          {stream, StreamRef, "$end_of_table", _} ->
              %% io:format("fold_stream_process: table complete: ~p.~p.~p~n",
              %%     [Index, Field, Term]),
              CatalogProcessPid ! {fold_stream, done, StreamRef};
          {stream, StreamRef, Value, Props} ->
              IndexBin = riak_search_utils:to_binary(Index),
              FieldTermBin = riak_search_utils:to_binary([Field, ".", Term]),
              BObj = term_to_binary({Field, Term, Value, Props}),
              FoldResultPid ! {fold_result, Fun0({IndexBin, FieldTermBin}, BObj, Acc)},
              fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, Fun0, Acc, Index, Field, Term);
          _Msg ->
              %% io:format("fold_stream_process: unknown message: ~p~n", [_Msg]),
              fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, Fun0, Acc, Index, Field, Term)
          after ?FOLD_TIMEOUT ->
              CatalogProcessPid ! {fold_stream, done, StreamRef},
  