anchor.diff:  %% @doc Stream list of keys in the bucket to the calling process.  The
   %%      process receives these messages.
   %%        {ReqId, {keys, [key()]}}
  -%%        {ReqId, done} 
  +%%        {ReqId, done}
   -spec stream_list_keys(pid(), bucket()) -> {ok, req_id()} | {error, term()}.
   stream_list_keys(Pid, Bucket) ->
       ReqMsg = #rpblistkeysreq{bucket = Bucket},
  
positive.code:                                  O=riakc_obj:new(<<"bucket">>, K),
                                   ?MODULE:put(Pid,riakc_obj:update_value(O, V, "application/json"))
                           end,
                   [Store(KV) || KV <- [{<<"foo">>, <<"2">>}, 
                                        {<<"bar">>, <<"3">>}, 
                                        {<<"baz">>, <<"4">>}]],
  
                   ?assertEqual({ok, [{1, [9]}]},
                                ?MODULE:mapred(Pid, 
                                               [{<<"bucket">>, <<"foo">>},
                                                {<<"bucket">>, <<"bar">>},
                                                {<<"bucket">>, <<"baz">>}],
  
negative.code:     {ok, _} = supervisor:restart_child({riak_core_sup, ?TEST_RIAK_NODE}, riak_core_ring_manager),
      {ok, _} = supervisor:restart_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_sup),
      {ok, _} = supervisor:restart_child({riak_kv_sup, ?TEST_RIAK_NODE}, riak_kv_vnode_master).
  
  
  pause_riak_pb_sockets() ->
      Children = supervisor:which_children({riak_kv_pb_socket_sup, ?TEST_RIAK_NODE}),
  