anchor.diff:                        end, RemElems),
       Op = case length(Adds) of
                0 -> [];
  -             1 -> [{update, Key, riak_dt_orset, {{add,Adds}, node()}}];
  -             _ -> [{update, Key, riak_dt_orset, {{add_all, Adds},node()}}]
  +             1 -> [{update, {Key, riak_dt_orset, {{add,Adds}, node()}}}];
  +             _ -> [{update, {Key, riak_dt_orset, {{add_all, Adds},node()}}}]
            end, 
       case length(Rems) of
           0 -> Op;
  -        1 -> [{update, Key, riak_dt_orset, {{remove,Adds}, ignore}}] ++ Op;
  -        _ -> [{update, Key, riak_dt_orset, {{remove_all, Adds},ignore}}] ++ Op
  +        1 -> [{update, {Key, riak_dt_orset, {{remove,Adds}, ignore}}}] ++ Op;
  +        _ -> [{update, {Key, riak_dt_orset, {{remove_all, Adds},ignore}}}] ++ Op
       end.
           
   
  
positive.code:                 end, [], Ops).
  %% Counter
  decode_au_txn_op(#fpbatomicupdatetxnop{counterinc=#fpbincrementreq{key=Key, amount=Amount}}) ->
      [{update, Key, riak_dt_pncounter, {{increment, Amount}, node()}}];
  decode_au_txn_op(#fpbatomicupdatetxnop{counterdec=#fpbdecrementreq{key=Key, amount=Amount}}) ->
      [{update, Key, riak_dt_pncounter, {{decrement, Amount}, node()}}];
  %% Set
  decode_au_txn_op(#fpbatomicupdatetxnop{setupdate=#fpbsetupdatereq{key=Key, adds=AddElems, rems=RemElems}}) ->
       Adds = lists:map(fun(X) ->
  
negative.code:     lists:map(fun(Resp) ->
                        encode_snapshot_read_resp(Resp)
                end, Zipped).
  encode_snapshot_read_resp({{read, {Key, riak_dt_pncounter}}, Result}) ->
      #fpbsnapshotreadtxnrespvalue{key=Key,counter=#fpbgetcounterresp{value =Result}};
  encode_snapshot_read_resp({{read,{Key,riak_dt_orset}}, Result}) ->
      #fpbsnapshotreadtxnrespvalue{key=Key,set=#fpbgetsetresp{value = term_to_binary(Result)}}.
  