anchor.diff:  after_send(#request{msg = #rpblistkeysreq{}, ctx = {ReqId, _Client}}, State) ->
       {reply, {ok, ReqId}, State};
   after_send(#request{msg = #rpbmapredreq{}, ctx = {ReqId, _Client}}, State) ->
  +    {reply, {ok, ReqId}, State};
  +after_send(#request{msg = #rpbindexreq{stream=true}, ctx = {ReqId, _Client}}, State) ->
       {reply, {ok, ReqId}, State};
   after_send(_Request, State) ->
       {noreply, State}.
  
positive.code:     Req = search_options(Options, #rpbsearchqueryreq{q = SearchQuery, index = Index}),
      gen_server:call(Pid, {req, Req, Timeout}, CallTimeout).
  
  %% @doc Execute a secondary index equality query.
  -spec get_index_eq(pid(), bucket(), binary() | secondary_index_id(), key() | integer()) ->
                         {ok, index_result()} | {error, term()}.
  get_index_eq(Pid, Bucket, {binary_index, Name}, Key) when is_binary(Key) ->
      Index = list_to_binary(lists:append([Name, "_bin"])),
      get_index_eq(Pid, Bucket, Index, Key);
  get_index_eq(Pid, Bucket, {integer_index, Name}, Key) when is_integer(Key) ->
      Index = list_to_binary(lists:append([Name, "_int"])),
      BinKey = list_to_binary(integer_to_list(Key)),
      get_index_eq(Pid, Bucket, Index, BinKey);
  get_index_eq(Pid, Bucket, Index, Key) ->
      Timeout = default_timeout(get_index_timeout),
      CallTimeout = default_timeout(get_index_call_timeout),
      get_index_eq(Pid, Bucket, Index, Key, [{timeout, Timeout}, {call_timeout, CallTimeout}]).
  
  %% @doc Execute a secondary index equality query with specified
  %% timeouts.
  -spec get_index_eq(pid(), bucket(), binary() | secondary_index_id(), key() | integer(), index_opts()) ->
                         {ok, index_result()} | {error, term()}.
  get_index_eq(Pid, Bucket, {binary_index, Name}, Key, Opts) when is_binary(Key) ->
  
negative.code:                    {req, Req, Timeout}
             end,
      gen_server:call(Pid, Call, CallTimeout).
  
  
  
  encode_2i(Value) when is_integer(Value) ->
      list_to_binary(integer_to_list(Value));
  