anchor.diff:  %%      and a final {ReqId, done} message.
   %%      None of the Keys lists will be larger than the number of
   %%      keys in Bucket on any single vnode.
  -%%      If ClientType is set to 'mapred' instead of 'plain', then the
  -%%      messages will be sent in the form of a MR input stream.
  -stream_list_keys(Input, Timeout, Client, ClientType) when is_pid(Client) ->
  +stream_list_keys(Input, Timeout, Client) when is_pid(Client) ->
       ReqId = mk_reqid(),
       case Input of
           {Bucket, FilterInput} ->
  
positive.code:     Me = self(),
      stream_list_keys(Bucket, Timeout, Me).
  
  stream_list_keys(Bucket, Timeout, Client) when is_pid(Client) ->
      stream_list_keys(Bucket, Timeout, Client, plain).
  
  %% @spec stream_list_keys(riak_object:bucket(),
  %%                        TimeoutMillisecs :: integer(),
  %%                        Client :: pid(),
  %%                        ClientType :: atom()) ->
  %%       {ok, ReqId :: term()}
  %% @doc List the keys known to be present in Bucket.
  %%      Key lists are updated asynchronously, so this may be slightly
  
negative.code: -export([delete/2,delete/3,delete/4]).
  -export([delete_vclock/3,delete_vclock/4,delete_vclock/5]).
  -export([list_keys/1,list_keys/2,list_keys/3]).
  -export([stream_list_keys/1,stream_list_keys/2,stream_list_keys/3]).
  -export([filter_buckets/1]).
  -export([filter_keys/2,filter_keys/3]).
  -export([list_buckets/0,list_buckets/2]).
  