anchor.diff:      ReturnTerms = proplists:get_value(return_terms, Opts),
       MaxResults = proplists:get_value(max_results, Opts),
       Stream = proplists:get_value(stream, Opts, false),
  +    Continuation = proplists:get_value(continuation, Opts),
   
       Req = #rpbindexreq{bucket=Bucket, index=Index, qtype=range,
                          range_min=encode_2i(StartKey),
                          range_max=encode_2i(EndKey),
                          return_terms=ReturnTerms,
                          max_results=MaxResults,
  -                       stream=Stream},
  +                       stream=Stream,
  +                       continuation=Continuation},
       Call = case Stream of
                  true ->
                      ReqId = mk_reqid(),
  
positive.code: process_response(#request{msg = #rpbindexreq{}}, rpbindexresp, State) ->
      {reply, {ok, []}, State};
  process_response(#request{msg = #rpbindexreq{stream=true, return_terms=Terms}}=Request,
                   #rpbindexresp{results=Results, keys=Keys, done=Done}, State) ->
      case {Terms, Results, Keys} of
          {_, undefined, undefined} -> ok;
          {true, Res, _} ->
              send_caller({results, Res}, Results);
          {fale, _, Res} ->
              send_caller({keys, Res}, Request)
      end,
      Reply = case Done of
                  true -> {reply, done, State};
                  1 -> {reply, done, State};
                  _ -> {pending, State}
              end,
      Reply;
  process_response(#request{msg = #rpbindexreq{return_terms=true}}, #rpbindexresp{results=Results}, State) ->
      {reply, {ok, Results}, State};
  process_response(#request{msg = #rpbindexreq{}}, #rpbindexresp{keys=Keys}, State) ->
      {reply, {ok, Keys}, State};
  
  process_response(#request{msg = #rpbsearchqueryreq{}}, rpbsearchqueryresp, State) ->
      {reply, {error, notfound}, State};
  
negative.code:     CallTimeout = proplists:get_value(call_timeout, Opts, default_timeout(get_index_call_timeout)),
      MaxResults = proplists:get_value(max_results, Opts),
      Stream = proplists:get_value(stream, Opts, false),
      Continuation = proplists:get_value(continuation, Opts),
  
      Req = #rpbindexreq{bucket=Bucket, index=Index, qtype=eq,
                         key=encode_2i(Key),
                         max_results=MaxResults,
                         stream=Stream,
                         continuation=Continuation},
      Call = case Stream of
                 true ->
                     ReqId = mk_reqid(),
  