anchor.diff:              {error, {format, Reason}, State}
       end.
   
  +-spec check_bucket_type(optional(binary())) -> {ok, binary()} | error.
   check_bucket_type(undefined) -> {ok, <<"default">>};
   check_bucket_type(<<"default">>) -> {ok, <<"default">>};
   check_bucket_type(Type) ->
  
positive.code: 
  -module(riak_kv_pb_bucket).
  
  -include_lib("riak_pb/include/riak_kv_pb.hrl").
  
  -behaviour(riak_api_pb_service).
  
negative.code:     {error, {format, Error}, State#state{req = undefined, req_ctx = undefined}}.
  
  
  -spec do_list_buckets(binary(), optional(pos_integer()), optional(boolean()), #rpblistbucketsreq{}, #state{}) ->
                               {reply, tuple(), #state{}} |
                               {error, {format, iodata()}, #state{}}.
  do_list_buckets(Type, Timeout, true, Req, #state{client=C}=State) ->
      {ok, ReqId} = C:stream_list_buckets(none, Timeout, Type),
      {reply, {stream, ReqId}, State#state{req = Req, req_ctx = ReqId}};
  