anchor.diff:           search/3, search/4, search/5, search/6,
            get_index/4, get_index/5, get_index/6, get_index/7, %% @deprecated
            get_index_eq/4, get_index_range/5, get_index_eq/5, get_index_range/6,
  +         cs_bucket_fold/3,
            default_timeout/1,
            tunnel/4]).
   
  
positive.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, State) ->
      {noreply, State}.
  
negative.code: process_response(#request{msg = #rpbindexreq{return_terms=Terms}}, #rpbindexresp{results=Results, keys=Keys, continuation=Cont}, State) ->
      Response = process_index_response(Terms, Keys, Results),
      {reply, {ok, [Response, {continuation, Cont}]}, State};
  process_response(#request{msg = #rpbcsbucketreq{bucket=Bucket}}=Request, #rpbcsbucketresp{objects=Objects, done=Done, continuation=Cont}, State) ->
      %% TEMP - cs specific message for fold_objects
      ToSend =  case Objects of
                    undefined -> {objects, []};
                    _ ->
                        %% make client objects
                        CObjects = lists:foldr(fun(#rpbindexobject{key=Key,
                                                                   object=#rpbgetresp{content=Contents, vclock=VClock}}, Acc) ->
                                                       DContents = riak_pb_kv_codec:decode_contents(Contents),
                                                       [riakc_obj:new_obj(Bucket, Key, VClock, DContents) | Acc] end,
                                               [],
                                               Objects),
                        {objects, CObjects}
                end,
      case Cont of
          undefined ->
              send_caller(ToSend, Request);
          _ -> send_caller([ToSend, {continuation, Cont}], Request)
      end,
      Reply = case Done of
                  true -> {reply, done, State};
                  1 -> {reply, done, State};
                  _ -> {pending, State}
              end,
      Reply;
  process_response(#request{msg = #rpbsearchqueryreq{}}, prbsearchqueryresp, State) ->
      {reply, {error, notfound}, State};
  process_response(#request{msg = #rpbsearchqueryreq{index=Index}},
  