anchor.diff:        riak_ops:put(Pid, Bucket, "key1", 2, Resolve),
         riak_ops:put(Pid, Bucket, "key2", 1, Resolve),
         riak_ops:put(Pid, Bucket, "key_b", 1, Resolve)
  -  end.
  +  end,
  +  riak_ops:disconnect(Pid).
   
   %% i.e. riak_setup:clear("127.0.0.1", <<"set_a">>).
   clear(Ip, Bucket) ->
     Pid = riak_ops:connect(Ip),
     riak_ops:clear(Pid, Bucket),
  +  riak_ops:disconnect(Pid),
     ok.
   
   nuclear() ->
  
positive.code: count(Ip, Bucket) ->
    Pid = riak_ops:connect(Ip),
    io:format("Object in bucket: ~p~n", [riak_ops:count(Pid, Bucket)]),
    ok.
  
  %% i.e. riak_setup:keys("127.0.0.1", <<"set_a">>).
  keys(Ip, Bucket) ->
    Pid = riak_ops:connect(Ip),
    riak_ops:keys(Pid, Bucket).
  
  %% i.e. riak_setup:get("127.0.0.1", <<"set_a">>, <<"key">>).
  get(Ip, Bucket, Key) ->
    Pid = riak_ops:connect(Ip),
    riak_ops:get(Pid, Bucket, Key, fun(_, _) -> error(sibling) end).
  
  %%%_* Internal =========================================================
  create_objects(Pid, Bucket, N, P, B) ->
  
negative.code:   Keys = riak_ops:keys(Pid, Bucket),
    KeyVals = [{Key, riak_ops:get(Pid, Bucket, Key, fun() -> error(sibling) end)} ||
                Key <- Keys],
    riak_ops:disconnect(Pid),
    symmetric_dataset:verify(KeyVals, Expected).
  
  %% riak_setup:mini().
  