anchor.diff:                      end
                   end, FirstClock, Rest). 
   
  -filter_labels([], _StableTime, _MyId)->
  +filter_labels([], _StableTime, _MyId, _Delay)->
       [];
   
  -filter_labels([H|Rest], StableTime, MyId) ->
  +filter_labels([H|Rest], StableTime, MyId, Delay) ->
       {TimeStamp, ListLabels} = H,
       case TimeStamp =< StableTime of
           true ->
  -            case groups_manager_serv:filter_stream_leaf(ListLabels) of
  +            Now = saturn_utilities:now_milisec(),
  +            {FinalStream, Leftovers} = lists:foldl(fun({Time, Label}, {FinalStream0, Leftovers0}) ->
  +                                                case (Time + Delay) > Now of
  +                                                    true ->
  +                                                        {FinalStream0, Leftovers0 ++ [{Time, Label}]};
  +                                                    false ->
  +                                                        {FinalStream0 ++ [Label], Leftovers0 }
  +                                                end
  +                                              end, {[], []}, ListLabels),
  +            case groups_manager_serv:filter_stream_leaf(FinalStream) of
                   {ok, [], _} ->
                       noop;
                   {ok, _, no_indexnode} ->
  
positive.code:         error ->
              {StableSeq, PendingTS0} = {0, []}
      end,
      Labels1 = orddict:append(TimeStamp, Label, Labels0),
      case ((StableSeq + 1) == Seq) of
          true ->
              S1 = update_vclock(Seq, PendingTS0, Partition, TimeStamp, S0#state{labels=Labels1}),
  
negative.code:             S0#state{vclock=VClock1, seqs=Seqs1}
      end.
  
  deliver_labels(S0=#state{vclock=Clocks, labels=Labels0, myid=MyId, delay=Delay}) ->
      StableTime = compute_stable_time(Clocks),
      Labels1 = filter_labels(Labels0, StableTime, MyId, Delay),
      S0#state{labels=Labels1}.
  
  compute_stable_time(Clocks) ->
  