anchor.diff:  
   process_response(#rpbsetbucketreq{}, undefined,
                    rpbsetbucketresp, State) ->
  -    {reply, ok, State}.
  +    {reply, ok, State};
  +
  +process_response(#rpbmapredreq{content_type = ContentType}, {ReqId, Client},
  +                 #rpbmapredresp{done = Done, phase=PhaseId, response=Data}, State) ->
  +    case Data of
  +        undefined ->
  +            ok;
  +        _ ->
  +            Response = decode_mapred_resp(Data, ContentType),
  +            Client ! {ReqId, {mapred, PhaseId, Response}}
  +    end,
  +    case Done of
  +        1 ->
  +            Client ! {ReqId, done},
  +            {noreply, State};
  +        _ ->
  +            {pending, State}
  +    end.
         
   %%
   %% Called after sending a message - supports returning a
  
positive.code:     PbProps = riakc_pb:pbify_rpbbucketprops(BucketProps),
      Req = #rpbsetbucketreq{bucket = Bucket, props = PbProps},
      gen_server:call(Pid, {req, Req}).
  
  %% ====================================================================
  %% gen_server callbacks
  
negative.code: on_error(#rpblistkeysreq{}, {ReqId, Client},  ErrMsg, undefined) ->
      Client ! { ReqId, {error, ErrMsg}};
  on_error(rpblistbucketsreq, {ReqId, Client}, ErrMsg, undefined) ->
      Client ! { ReqId, {error, ErrMsg}};
  on_error(#rpbmapredreq{}, {ReqId, Client}, ErrMsg, undefined) ->
      Client ! { ReqId, {error, ErrMsg}};
  on_error(_Req, _Ctx, ErrMsg, From) when From =/= undefined ->
      gen_server:reply(From, {error, ErrMsg}).
  %% deliberately crash if the handling an error response after
  %% the client has been replied to
  
  %% Common code for sending a single bucket or multiple inputs map/request
  %% @private
  send_mapred_req(Pid, MapRed, ClientPid) ->
      ReqMsg = #rpbmapredreq{request = encode_mapred_req(MapRed),
                             content_type = <<"application/x-erlang-binary">>},
      ReqId = mk_reqid(),
      gen_server:call(Pid, {req, ReqMsg, {ReqId, ClientPid}}).
  
  %% Send a request to the server and prepare the state for the response
  %% @private
  