anchor.diff:  %% @doc process_stream/3 callback. Handle streamed responses
   process_stream({ReqId, done}, ReqId, State=#state{req_id=ReqId,
                                                     continuation=Continuation,
  -                                                  req=Req,
  +                                                  req=#rpbindexreq{return_body=false}=Req,
                                                     result_count=Count}) ->
       %% Only add the continuation if there (may) be more results to send
       #rpbindexreq{max_results=MaxResults} = Req,
       Resp = case is_integer(MaxResults) andalso Count >= MaxResults of
                  true -> #rpbindexresp{done=1, continuation=Continuation};
                  false -> #rpbindexresp{done=1}
  +           end,
  +    {done, Resp, State};
  +process_stream({ReqId, done}, ReqId, State=#state{req_id=ReqId,
  +                                                  continuation=Continuation,
  +                                                  req=Req,
  +                                                  result_count=Count}) ->
  +    %% Only add the continuation if there (may) be more results to send
  +    #rpbindexreq{max_results=MaxResults} = Req,
  +    Resp = case is_integer(MaxResults) andalso Count >= MaxResults of
  +               true -> #rpbindexbodyresp{done=1, continuation=Continuation};
  +               false -> #rpbindexbodyresp{done=1}
              end,
       {done, Resp, State};
   process_stream({ReqId, {results, []}}, ReqId, State=#state{req_id=ReqId}) ->
  
positive.code: %%
  %% <pre>
  %%  26 - RpbIndexResp
  %% </pre>
  %% @end
  
  
negative.code: 
  encode_results(objects, Results0, Continuation) ->
      Results = [encode_result(Res) || Res <- Results0],
      #rpbindexbodyresp{objects=Results, continuation=Continuation};
  encode_results(terms, Results0, Continuation) ->
      Results = [encode_result(Res) || Res <- Results0],
      #rpbindexresp{results=Results, continuation=Continuation};
  