anchor.diff:      case DestPartition == State#state.partition andalso Node == node() of
           true ->
               case SubType of
  -                all ->
  -                    SubType2 = 0;
  -                _ ->
  -                    SubType2 = SubType
  +                all -> SubType2 = 0;
  +                _ -> SubType2 = SubType
               end,
               case StartSubTerm of
  -                all ->
  -                    StartSubTerm2 = 0;
  -                _ ->
  -                    StartSubTerm2 = StartSubTerm
  +                all -> StartSubTerm2 = 0;
  +                _ -> StartSubTerm2 = StartSubTerm
               end,
               case EndSubTerm of
  -                all ->
  -                    EndSubTerm2 = 0;
  -                _ ->
  -                    EndSubTerm2 = EndSubTerm
  +                all -> EndSubTerm2 = 0;
  +                _ -> EndSubTerm2 = EndSubTerm
               end,
  -            
               spawn(fun() ->
                   {ok, StreamRef} = raptor_conn:stream(
                       Conn, 
  
positive.code: drop(_State) ->
      ok.
      %merge_index:drop(Pid).
      %%%% xxx TODO
  
  %% @spec delete(state(), BKey :: riak_object:bkey()) ->
  %%          ok | {error, Reason :: term()}
  
negative.code:             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()}, %% 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);
  