anchor.diff:  process(#rpbindexreq{qtype=range, range_min=Min, range_max=Max}, State)
     when not (is_binary(Min) andalso is_binary(Max)) ->
       {error, {format, "Invalid range query: ~p -> ~p", [Min, Max]}, State};
  -process(#rpbindexreq{bucket=Bucket, index=Index, qtype=eq, key=SKey}, ?state{client=Client}=State) ->
  +process(#rpbindexreq{bucket=Bucket, index=Index, qtype=eq, key=SKey}, #state{client=Client}=State) ->
       case riak_index:to_index_query(Index, [SKey]) of
           {ok, Query} ->
               case Client:get_index(Bucket, Query) of
  
positive.code:             {error, {format, Reason}, State}
      end;
  process(#rpbindexreq{bucket=Bucket, index=Index, qtype=range,
                       range_min=Min, range_max=Max}, ?state{client=Client}=State) ->
      case riak_index:to_index_query(Index, [Min, Max]) of
          {ok, Query} ->
              case Client:get_index(Bucket, Query) of
  
negative.code:          process/2,
           process_stream/3]).
  
  -record(state, {client}).
  
  %% @doc init/0 callback. Returns the service internal start
  %% state.
  -spec init() -> any().
  init() ->
      {ok, C} = riak:local_client(),
      #state{client=C}.
  
  %% @doc decode/2 callback. Decodes an incoming message.
  decode(Code, Bin) ->
  