anchor.diff:  %% @doc Initialize this resource.
   init(Props) ->
       {ok, #ctx{
  -       riak=proplists:get_value(riak, Props)
  +       riak=proplists:get_value(riak, Props),
  +       bucket_type=proplists:get_value(bucket_type, Props)
         }}.
   
   
  
positive.code: %%          {boolean(), reqdata(), context()}
  %% @doc Determine whether or not a connection to Riak
  %%      can be established. Also, extract query params.
  service_available(RD, Ctx=#ctx{riak=RiakProps}) ->
      case riak_kv_wm_utils:get_riak_client(RiakProps, riak_kv_wm_utils:get_client_id(RD)) of
          {ok, C} ->
              {true, RD, Ctx#ctx { client=C }};
  
negative.code: 
  handle_streaming_index_query(RD, Ctx) ->
      Client = Ctx#ctx.client,
      Bucket = riak_kv_wm_utils:maybe_bucket_type(Ctx#ctx.bucket_type, Ctx#ctx.bucket),
      Query = Ctx#ctx.index_query,
      MaxResults = Ctx#ctx.max_results,
      ReturnTerms = Ctx#ctx.return_terms,
  