anchor.diff:      Response = antidotec_pb_socket:atomic_store_crdts([C13,C21],Pid),
       ?assertMatch({ok,_},Response),
       {ok, Clock} = Response,
  -    %Read your writes
  +    %%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)),
  
positive.code:     {ok, C2} = antidotec_pb_socket:get_crdt(<<"counter2">>, riak_dt_pncounter, Pid),
      C11 = antidotec_counter:increment(1, C1),
      C21 = antidotec_counter:increment(2, C2),
      lager:info("Testing.. "),
      Msg = riak_pb_messages:msg_code(fpbatomicupdatetxnreq),
      lager:info("Msg Code is ~p",[Msg]),
      Response = antidotec_pb_socket:atomic_store_crdts([C11,C21],Pid),
      antidotec_pb_socket:stop(Pid),
      ?assertMatch({ok,_},Response),
  
      %Read your writes
      pass = get_crdt_check_value(<<"counter1">>, riak_dt_pncounter, 1),
      pass = get_crdt_check_value(<<"counter2">>, riak_dt_pncounter, 2),
      pass.
  
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.
  