anchor.diff:  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}}) ->
  +decode_au_txn_op(#fpbatomicupdatetxnop{setupdate=#fpbsetupdatereq{key=Key,adds=AddElems, rems=RemElems}}) ->
        Adds = lists:map(fun(X) ->
                                 binary_to_term(X)
                         end, AddElems),
  
positive.code: decode_snapshot_read_op(#fpbsnapshotreadtxnop{set=#fpbgetsetreq{key=Key}}) ->
      {read,Key, riak_dt_orset}.
  
  
  encode_snapshot_read_response(Zipped) ->
      lists:map(fun(Resp) ->
                        encode_snapshot_read_resp(Resp)
  
negative.code: process_stream(_,_,State) ->
      {ignore, State}.
  
  %% @doc decode_au_txn_ops : converts the pb messages for atomic update
  %% transaction into update messages for interface in antidote.erl
  -spec decode_au_txn_ops([#fpbatomicupdatetxnop{}]) ->
                                 [{update, key(), type(), op()}].
  decode_au_txn_ops(Ops) ->
      lists:foldl(fun(Op, Acc) ->
  