anchor.diff:  handle(Message) ->
       gen_server:call(?MODULE, Message, infinity).
   
  +delayed_delivery_completed(Node, Number) ->
  +    gen_server:call(?MODULE, {delayed_delivery_completed, Node, Number}).
   %% ------------------------------------------------------------------
   %% gen_server Function Definitions
   %% ------------------------------------------------------------------
   
   init([Nodes, MyId]) ->
  -    Queues = lists:foldl(fun(Node, Acc) ->
  -                            dict:store(Node, queue:new(), Acc)
  -                         end, dict:new(), Nodes),
  -    {ok, #state{queues=Queues, myid=MyId}}.
  +    {Queues, Busy} = lists:foldl(fun(Node,{Queues0, Busy0}) ->
  +                                    {dict:store(Node, queue:new(), Queues0), dict:store(Node, false, Busy0)}
  +                                 end, {dict:new(), dict:new()}, Nodes),
  +    {ok, #state{queues=Queues, myid=MyId, busy=Busy, delay=100}}.
   
  -handle_call({new_stream, Stream, IdSender}, _From, S0=#state{queues=Queues0, myid=MyId}) ->
  +handle_call({delayed_delivery_completed, Node, Number}, _From, S0=#state{queues=Queues0, busy=Busy0}) ->
  +    Queue0 = dict:fetch(Node, Queues0),
  +    List0 = queue:to_list(Queue0),
  +    Length = length(List0),
  +    case Length == Number of
  +        true ->
  +            List1 = [];
  +        false ->
  +            List1 = lists:sublist(List0, Number + 1, Length - Number)
  +    end,
  +    Queue1 = queue:from_list(List1),
  +    Queues1 = dict:store(Node, Queue1, Queues0),
  +    Busy1 = dict:store(Node, false, Busy0),
  +    {noreply, S0#state{queues=Queues1, busy=Busy1}};
  +    
  +handle_call({new_stream, Stream, IdSender}, _From, S0=#state{queues=Queues0}) ->
  +    Now = now_milisec(),
       Queues1 = lists:foldl(fun(Label, Acc0) ->
                               {Key, _Clock, _Node} = Label,
                               lists:foldl(fun(Node, Acc1) ->
  
positive.code:          terminate/2, code_change/3]).
  
  -record(state, {queues :: dict(),
                  myid}).
  
  %% ------------------------------------------------------------------
  
negative.code: 
  -export([start_link/2]).
  
  -export([handle/1,
           delayed_delivery_completed/2,
           deliver_delayed/4]).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Exports
  