anchor.diff:              riak_kv_keys_fsm:ack_keys(From),
               wait_for_listkeys(ReqId, [Res|Acc]);
           {ReqId,{keys,Res}} -> wait_for_listkeys(ReqId, [Res|Acc]);
  -        {ReqId, {error, Error}} -> {error, Error}
  +        {ReqId, {error, Error}} ->
  +            {error, Error}
       end.
   
   %% @private
   wait_for_listbuckets(ReqId) ->
       receive
  -        {ReqId,{buckets, Buckets}} -> 
  +        {ReqId,{buckets, Buckets}} ->
               {ok, Buckets};
  -        {ReqId, Error} -> 
  +        {ReqId, {error, Error}} ->
               {error, Error}
       end.
   
  
positive.code: %%      out of date if called immediately after any operation that
  %%      either adds the first key or removes the last remaining key from
  %%      a bucket.
  stream_list_buckets(Filter, Timeout, Client, 
                      {?MODULE, [_Node, _ClientId]}=THIS) when is_pid(Client) ->
      stream_list_buckets(Filter, Timeout, Client, <<"default">>, THIS);
  stream_list_buckets(Filter, Timeout, Type,
  
negative.code: 
  stream_list_buckets(undefined, {?MODULE, [_Node, _ClientId]}=THIS) ->
      stream_list_buckets(none, ?DEFAULT_TIMEOUT, THIS);
  stream_list_buckets(Timeout, {?MODULE, [_Node, _ClientId]}=THIS)
    when is_integer(Timeout) ->
      stream_list_buckets(none, Timeout, THIS);
  stream_list_buckets(Filter, {?MODULE, [_Node, _ClientId]}=THIS)
    when is_function(Filter) ->
      stream_list_buckets(Filter, ?DEFAULT_TIMEOUT, THIS).
  
  