anchor.diff:      {ok, Obj} = antidotec_pb_socket:get_crdt(Key, riak_dt_pncounter, Pid),
       Obj2 = antidotec_counter:increment(Amount, Obj),
       Result = antidotec_pb_socket:store_crdt(Obj2, Pid),
  -     _Disconnected = antidotec_pb_socket:stop(Pid),
  +    _Disconnected = antidotec_pb_socket:stop(Pid),
       ?assertMatch(ok, Result),
       pass.
   
  
positive.code:     Response = antidotec_pb_socket:atomic_store_crdts([C13,C21],Pid),
      ?assertMatch({ok,_},Response),
      {ok, Clock} = Response,
      %Read your writes
      Result = antidotec_pb_socket:snapshot_get_crdts([{Key1, riak_dt_orset}, {Key2,riak_dt_pncounter}], Clock, Pid),
      {ok, Clock1, [Set1, Counter2]} = Result,
      
      ?assertMatch(2, antidotec_counter:value(Counter2)),
      ?assertMatch(true, antidotec_set:contains(1,Set1)),
      ?assertMatch(true, antidotec_set:contains(2,Set1)),
  
negative.code:     Result2 = antidotec_pb_socket:snapshot_get_crdts([{Key1,riak_dt_orset}], Clock2, Pid),
      {ok, _, [Set2]} = Result2,
      ?assertMatch(false, antidotec_set:contains(3,Set2)),
      antidotec_pb_socket:stop(Pid),
      pass.
  