anchor.diff:                                                  _ ->
                                                       case groups_manager_serv:interested(Node, BKey) of
                                                           {ok, true} ->
  +                                                            case Label#label.operation of
  +                                                                update ->
  +                                                                    Now = now_microsec(),
  +                                                                    Time = Now + Delay;
  +                                                                _ ->
  +                                                                    Time = 0
  +                                                            end,
                                                               Queue0 = dict:fetch(Node, Acc1),
  -                                                            Queue1 = queue:in({Label, Now}, Queue0),
  +                                                            Queue1 = queue:in({Time, Label}, Queue0),
                                                               dict:store(Node, Queue1, Acc1);
                                                           {ok, false} -> Acc1
                                                       end
                                               end
                                           end, Acc0, dict:fetch_keys(Queues0))
                             end, Queues0, Stream),
  -    S1 = lists:foldl(fun(Node, State) ->
  -                        deliver_labels(Node, State)
  -                     end, S0#state{queues=Queues1}, dict:fetch_keys(Queues1)),
  -    {reply, ok, S1};
  +    {Queues2, Busy1} = lists:foldl(fun(Node, {Acc1, Acc2}) ->
  +                                    case dict:fetch(Node, Busy0) of
  +                                        false ->
  +                                            {NewQueue, NewPending} = deliver_labels(dict:fetch(Node, Queues1), Node, MyId, []),
  +                                            {dict:store(Node, NewQueue, Acc1), dict:store(Node, NewPending, Acc2)};
  +                                        true ->
  +                                            OldQueue = dict:fetch(Node, Queues1),
  +                                            {dict:store(Node, OldQueue, Acc1), dict:store(Node, true, Acc2)}
  +                                    end
  +                                   end, {dict:new(), dict:new()}, dict:fetch_keys(Queues1)),
  +    {reply, ok, S0#state{queues=Queues2, busy=Busy1}};
   
   handle_call(_Request, _From, State) ->
       {reply, ok, State}.
  
positive.code: 
  -record(state, {queues :: dict(),
                  busy :: dict(),
                  delay,
                  myid}).
  
  %% ------------------------------------------------------------------
  
negative.code: -export([start_link/2]).
  
  -export([handle/1,
           handle/2]).
  
  %% ------------------------------------------------------------------
  %% gen_server Function Exports
  