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: 
  % @type state() = term().
  -record(state, {partition, conn}).
  
  -define(CATALOG_TABLE, "__sys._catalog_").
  
  %% @spec start(Partition :: integer(), Config :: proplist()) ->
  %%          {ok, state()} | {{error, Reason :: term()}, state()}
  
negative.code: drop(_State) ->
      ok.
      %merge_index:drop(Pid).
      % xxx TODO
  
  %% @spec delete(state(), BKey :: riak_object:bkey()) ->
  %%          ok | {error, Reason :: term()}
  