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: list_buckets(Filter, Timeout) ->
      Me = self(),
      ReqId = mk_reqid(),
      riak_kv_buckets_fsm_sup:start_buckets_fsm(Node, [{raw, ReqId, Me}, [Filter, Timeout]]),
      wait_for_listbuckets(ReqId, Timeout).
  
  %% @spec filter_buckets(Fun :: function()) ->
  