anchor.diff:  recover(S,SubRecord) ->
       lists:foldl(fun set_sub/2,S,SubRecord).
   
  +maybe_clean_garbage(Garbage) ->
  +    %%@todo: perform cleanup
  +    ok.
  +
   maybe_demonitor_reg(undefined,Mons) ->
       Mons;
   maybe_demonitor_reg(Ref,Mons)       ->
  
positive.code: 
  -include("mqtt_internal_msgs.hrl").
  
  -behaviour(gen_server).
  
  %% API
  
negative.code: handle_new_packet(Packet,QoS,_From,S = #state{live_subs = Subs,
                                                queue = SQ}) ->
  
      SQ1 = shared_queue:pushr({QoS,Packet},SQ),
      Max = shared_queue:max_seq(SQ1),
      {PushTo,Subs1} = dict:fold(fun(ClientId,Sub,AccIn = {PushToAcc,SubsAcc}) ->
                                      case maybe_update_waiting_sub(Max,Sub) of
  