anchor.diff:          _ -> [{update, Key, riak_dt_orset, {{remove_all, Rems},ignore}}] ++ Op
       end.
           
  -
  +-spec decode_snapshot_read_ops([#fpbsnapshotreadtxnop{}]) ->
  +                                      [{read, key(), type()}].
   decode_snapshot_read_ops(Ops) ->
       lists:map(fun(Op) ->
                         decode_snapshot_read_op(Op)
  
positive.code: process_stream(_,_,State) ->
      {ignore, State}.
  
  decode_au_txn_ops(Ops) ->
      lists:foldl(fun(Op, Acc) ->
                       Acc ++ decode_au_txn_op(Op)
  
negative.code:     {read,Key, riak_dt_orset}.
  
  
  encode_snapshot_read_response(Zipped) ->
      lists:map(fun(Resp) ->
                        encode_snapshot_read_resp(Resp)
  