anchor.diff:  -type index_opts() :: [index_opt()].
   -type range_index_opt() :: {return_terms, boolean()}.
   -type range_index_opts() :: [index_opt() | range_index_opt()].
  +-type cs_opt() :: {timeout, timeout()} |
  +                  {continuation, binary()} |
  +                  {max_results, non_neg_integer() | all} |
  +                  {start_key, binary()} |
  +                  {start_incl, boolean()} |
  +                  {end_key, binary()} |
  +                  {end_incl, boolean()}.
  +-type cs_opts() :: [cs_opt()].
   
   %% Which client operation the default timeout is being requested
   %% for. `timeout' is the global default timeout. Any of these defaults
  
positive.code:            end,
      gen_server:call(Pid, Call, CallTimeout).
  
  
  
  encode_2i(Value) when is_integer(Value) ->
      list_to_binary(integer_to_list(Value));
  encode_2i(Value) when is_list(Value) ->
      list_to_binary(Value);
  encode_2i(Value) when is_binary(Value) ->
      Value.
  
  %% @doc Return the default timeout for an operation if none is provided.
  %%      Falls back to the default timeout.
  
negative.code: 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{msg = #rpbcsbucketreq{}, ctx = {ReqId, _Client}}, State) ->
      {reply, {ok, ReqId}, State};
  after_send(_Request, State) ->
      {noreply, State}.
  