anchor.diff:              Props2 = binary_to_term(Props),
               IndexBin = riak_search_utils:to_binary(Index),
               FieldTermBin = riak_search_utils:to_binary([Field, ".", Term]),
  -            Payload = {index, Index, Field, Term, 0, 0, Value, Props2, erlang:now()},
  +            Payload = {index, Index, Field, Term, 0, 0, Value, Props2, erlang:now()}, %% todo: sub type, startterm, endterm (tbd)
               BObj = term_to_binary(riak_object:new(IndexBin, FieldTermBin, Payload)),
               FoldResultPid ! {fold_result, Fun0({IndexBin, FieldTermBin}, BObj, Acc)},
               fold_stream_process(CatalogProcessPid, FoldResultPid, StreamRef, Fun0, Acc, Index, Field, Term);
  
positive.code:                                  StreamProcessCount+1, FinishedStreamProcessCount);
  
          {fold_stream, done, _StreamRef1} ->
              case FinishedStreamProcessCount >= (StreamProcessCount-1) of
                  true ->
                      case CatalogDone of
                          true ->
                              FoldResultPid ! {fold_result, done},
                              fold_catalog_process(FoldResultPid, Fun0, Acc, CatalogDone,
                                  StreamProcessCount, FinishedStreamProcessCount+1);
                          false ->
                              fold_catalog_process(FoldResultPid, Fun0, Acc, CatalogDone,
                                  StreamProcessCount, FinishedStreamProcessCount+1)
                      end;
                  _ -> 
                      fold_catalog_process(FoldResultPid, Fun0, Acc, CatalogDone,
                          StreamProcessCount, FinishedStreamProcessCount+1)
              end,
              fold_catalog_process(FoldResultPid, Fun0, Acc, CatalogDone,
                  StreamProcessCount, FinishedStreamProcessCount+1);
          Msg ->
              io:format("fold_catalog_process: unknown message: ~p~n", [Msg]),
              fold_catalog_process(FoldResultPid, Fun0, Acc, CatalogDone,
  
negative.code: 
  handle_command(State, {index, Index, Field, Term, Value, Props}) ->
      TS = mi_utils:now_to_timestamp(erlang:now()),
      handle_command(State, {index, Index, Field, Term, 0, 0, Value, Props, TS}); %% todo: sub type, startterm, endterm (tbd)
  
  handle_command(State, {index, Index, Field, Term, SubType, SubTerm, Value, Props, _Timestamp}) ->
      %% Put with properties.
  