anchor.diff:  -record(ctx, {
             client,       %% riak_client() - the store client
             riak,         %% local | {node(), atom()} - params for riak client
  +          bucket_type,  %% Bucket type (from uri)
             bucket,       %% The bucket to query.
             index_query,   %% The query..
             max_results :: all | pos_integer(), %% maximum number of 2i results to return, the page size.
  
positive.code: 
  handle_streaming_index_query(RD, Ctx) ->
      Client = Ctx#ctx.client,
      Bucket = Ctx#ctx.bucket,
      Query = Ctx#ctx.index_query,
      MaxResults = Ctx#ctx.max_results,
      ReturnTerms = Ctx#ctx.return_terms,
  
negative.code:          malformed_request/2,
           content_types_provided/2,
           encodings_provided/2,
           resource_exists/2,
           produce_index_results/2
          ]).
  
  