anchor.diff:                  _ ->
                       send_msg(#rpbputresp{}, State)
               end;
  -        {error, precommit_fail} ->
  -            send_error("precommit fail", [], State);
  -        {error, {precommit_fail, Reason}} ->
  -            send_error("precommit fail - ~p", [Reason], State);
           {error, Reason} ->
               send_error("~p", [Reason], State)
       end;
  
positive.code:                 #state{client=C} = State) ->
      case C:list_buckets() of
          {ok, Buckets} ->
              send_msg(#rpblistbucketsresp{buckets = Buckets, done = 1}, State);
          {error, Reason} ->
              send_error("~p", [Reason], State)
      end;
  
  %% Start streaming in list keys - results will be processed in handle_info
  process_message(#rpblistkeysreq{bucket=B}=Req, 
                  #state{client=C} = State) ->
      case C:stream_list_keys(B) of
          {ok, ReqId} ->
              {pause, State#state{req = Req, req_ctx = ReqId}}
      end.
  
  %% @private
  %% @doc if return_body was requested, call the client to get it and return
  
negative.code:             send_msg(rpbdelresp, State);
          {error, notfound} ->  %% delete succeeds if already deleted
              send_msg(rpbdelresp, State);
          {error, Reason} ->
              send_error("~p", [Reason], State)
      end;
  