anchor.diff:  
   -record(state, {queues :: dict(),
                   busy :: dict(),
  -                delay, %has to be in microsecs
  +                delays, %has to be in microsecs
                   myid}).
   
   %% ------------------------------------------------------------------
  
positive.code:     done;
  
  propagate_stream(Node, Stream, MyId) ->
      lager:info("Stream to propagate to ~p: ~p", [Node, Stream]),
      case ?PROPAGATION_MODE of
          naive_erlang ->
              case groups_manager_serv:is_leaf(Node) of
  
negative.code:     {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, Delays0} = groups_manager_serv:get_delays_internal(),
      Delays1 = lists:foldl(fun({Node, Delay}, Dict) ->
                              dict:store(Node, Delay*1000, Dict)
                            end, dict:new(), dict:to_list(Delays0)),
      {ok, #state{queues=Queues, myid=MyId, busy=Busy, delays=Delays1}}.
  
  handle_call({new_stream, Stream, IdSender}, _From, S0=#state{queues=Queues0, busy=Busy0, delays=Delays, myid=MyId}) ->
      Queues1 = lists:foldl(fun(Label, Acc0) ->
                              BKey = Label#label.bkey,
                              lists:foldl(fun(Node, Acc1) ->
  