anchor.diff:  
   multiple_writes(Node, Start, End)->
       F = fun(N, Acc) ->
  -            case rpc:call(Node, antidote, append, [N, antidote_crdt_counter, {increment, N}]) of
  +            case rpc:call(Node, antidote, append, [N, antidote_crdt_gset, {add, {N, actor}}]) of
                   {ok, _} ->
                       Acc;
                   Other ->
                       [{N, Other} | Acc]
               end
       end,
  -    lists:foldl(F, [], lists:seq(Start, End)).
  +    Res = lists:foldl(F, [], lists:seq(Start, End)),
  +    ?assertEqual(0, length(Res)).
   
   multiple_reads(Node, Start, End) ->
       F = fun(N, Acc) ->
  -            case rpc:call(Node, antidote, read, [N, antidote_crdt_counter]) of
  +            case rpc:call(Node, antidote, read, [N, antidote_crdt_gset]) of
                   {error, _} ->
                       [{N, error} | Acc];
  -                {ok, Value} ->
  +                {ok, [Value]} ->
                       case Value =:= N of
                           true ->
                               Acc;
  
positive.code: 
      lager:info("Waiting until vnodes are started up"),
      rt:wait_until(RootNode,fun wait_init:check_ready/1),
      lager:info("Vnodes are started up"),
  
      lager:info("Populating root node."),
  
negative.code: 
      %% Test handoff on each node:
      lager:info("Testing handoff for cluster."),
  
      %% Prepare for the next call to our test (we aren't polite about it,
      %% it's faster that way):
  