anchor.diff:           get_bucket/2,
            set_bucket/3,
            mapred/3, mapred/4,
  -         mapred_stream/5,
  +         mapred_stream/4, mapred_stream/5,
            mapred_bucket/3, mapred_bucket/4,
            mapred_bucket_stream/5]).
   
  
positive.code:     wait_for_mapred(ReqId, Timeout).
  
  %% @spec mapred_stream(Pid :: pid(),
  %%                     Query :: [riak_kv_mapred_query:mapred_queryterm()],
  %%                     ClientPid :: pid()) ->
  %%       {ok, {ReqId :: term(), MR_FSM_PID :: pid()}} |
  
negative.code: %% @doc Perform a streaming map/reduce job across the cluster sending results
  %%      to ClientPid.
  %%      See the map/reduce documentation for explanation of behavior.
  mapred_stream(Pid, Inputs, Query, ClientPid) ->
      mapred_stream(Pid, Inputs, Query, ClientPid,?DEFAULT_TIMEOUT).
  
  %% @spec mapred_stream(Pid :: pid(),
  %%                     Inputs :: list(),
  