anchor.diff:  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}.
  
positive.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 = #rpbsearchqueryreq{}}, prbsearchqueryresp, State) ->
      {reply, {error, notfound}, State};
  process_response(#request{msg = #rpbsearchqueryreq{index=Index}},
  
negative.code:          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]).
  
  