anchor.diff:      shared_queue:add(ClientId,0,Q).
   
   recover(SubRecord,S = #state{queue = Q}) ->
  -    lists:foldl(fun recover_sub/2,Q,SubRecord).
  -
  +    Q1 = lists:foldl(fun recover_sub/2,Q,SubRecord),
  +    S#state{queue = Q1}.
  +
  
positive.code: %%% Handling Packets and Acks
  %%%===================================================================
  
  -spec(is_less_than(client_seq(),client_seq()) -> boolean()).
  is_less_than(A,B) -> compare(A,B) =:= lt.
  
  -type(order() :: gt | lt | eq).
  -type(partial_order() :: order() | undefined).
  -type(client_seq():: undefined
                      | non_neg_integer()
                      | complete).
  -spec(compare(client_seq(),client_seq())-> order()).
  
  compare(A,A)               -> eq;
  
negative.code:     {ok,#state{filter = Filter,
                 live_subs = dict:new(),
                 packet_seq = Seq,
                 queue = shared_queue:new(Seq),
                 retained = shared_set:new()}}.
  
  %%--------------------------------------------------------------------
  