anchor.diff:  handle_request_for_more(ClientId,FromSeq,WSize,S = #state{live_subs = Subs,
                                                             queue = SQ}) ->
       S1 = case dict:find(ClientId,Subs) of
  -        {ok,Sub = #sub{pid = Pid}} ->
  -            MaxSeq = shared_queue:max_seq(SQ),
  -            {ok,{From,To},Sub1} = packet_range_to_send(MaxSeq,FromSeq,WSize,Sub),
  -            Packets = shared_queue:read(From,To,SQ),
  -            S2 = S#state{live_subs = dict:update(ClientId,Sub1,Subs)},
  -            send_packets_to_client(Pid,Packets,S2),
  -            S2;
  -        error ->
  -            S
  -     end,
  +            {ok,Sub = #sub{pid = Pid}} ->
  +                MaxSeq = shared_queue:max_seq(SQ),
  +                {ok,{From,To},Sub1} = packet_range_to_send(MaxSeq,FromSeq,WSize,Sub),
  +                Packets = shared_queue:read(From,To,SQ),
  +                S2 = S#state{live_subs = dict:update(ClientId,Sub1,Subs)},
  +                send_packets_to_client(Pid,Packets,S2),
  +                S2;
  +            error ->
  +                S
  +        end,
       {ok,{reply,ok},S1}.
   
   handle_ack(ClientId,AckSeq,S = #state{queue = SQ,garbage = Garbage}) ->
  
positive.code:                                     end
                                end,
                      {[],Subs},Subs),
      S1 = S#state{live_subs = Subs1,
                   queue = SQ1},
      send_packet_to_clients(SendTo,Packet,QoS),
      {reply,{ok,Max},S1}.
  
  
negative.code: %%
  
  handle_new_packet(Packet,QoS,_From,S = #state{live_subs = Subs,
                                                retained = Ret,
                                                queue = SQ}) ->
  
      SQ1 = shared_queue:pushr({QoS,Packet},SQ),
  