anchor.diff:  process_stream(_,_,State) ->
       {ignore, State}.
   
  +-spec decode_au_txn_ops([#fpbatomicupdatetxnop{}]) -> 
  +                               [{update, key(), type(), op()}].
   decode_au_txn_ops(Ops) ->
       lists:foldl(fun(Op, Acc) ->
                        Acc ++ decode_au_txn_op(Op)
  
positive.code:         _ -> [{update, Key, riak_dt_orset, {{remove_all, Rems},ignore}}] ++ Op
      end.
          
  
  decode_snapshot_read_ops(Ops) ->
      lists:map(fun(Op) ->
                        decode_snapshot_read_op(Op)
  
negative.code: -behaviour(riak_api_pb_service).
  
  -include_lib("riak_pb/include/antidote_pb.hrl").
  -include("antidote.hrl").
  
  -export([init/0,
           decode/2,
  