anchor.diff:              {error, {format, Reason}, State}
       end;
   process(#rpbindexreq{bucket=Bucket, index=Index, qtype=range,
  -                     range_min=Min, range_max=Max}, ?state{client=Client}=State) ->
  +                     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
  
positive.code:          process/2,
           process_stream/3]).
  
  -record(?MODULE, {client}).
  -define(state, #?MODULE).
  
  %% @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) ->
  
negative.code: %% -------------------------------------------------------------------
  %%
  %% riak_kv_pb_index: Expose secondary index queries to Protocol Buffers
  %%
  %% Copyright (c) 2012 Basho Technologies, Inc.  All Rights Reserved.
  %%
  