anchor.diff:      end,
       {noreply, S2};
   
  +handle_cast({label_delivered, Element}, S0=#state{labels=Labels0})->
  +    [{TimeStamp, ListLabels}|Rest] = Labels0,
  +    case lists:delete(Element, ListLabels) of
  +        [] ->
  +            S1 = deliver_labels(S0#state{labels=Rest});
  +        Other ->
  +            Labels1 = [{TimeStamp, Other}] ++ Rest,
  +            S1 = S0#state{labels=Labels1}
  +    end,
  +    {noreply, S1};
  +    
   handle_cast(_Info, State) ->
       {noreply, State}.
   
  
positive.code:                     end
                  end, FirstClock, Rest). 
  
  filter_labels([], _StableTime, _MyId)->
      [];
  
  filter_labels([H|Rest], StableTime, MyId) ->
      {TimeStamp, ListLabels} = H,
      case TimeStamp =< StableTime of
          true ->
              case groups_manager_serv:filter_stream_leaf(ListLabels) of
                  {ok, [], _} ->
                      noop;
                  {ok, _, no_indexnode} ->
  
negative.code:         error ->
              {StableSeq, PendingTS0} = {0, []}
      end,
      Labels1 = orddict:append(TimeStamp, {Now, Label}, Labels0),
      case ((StableSeq + 1) == Seq) of
          true ->
              S1 = update_vclock(Seq, PendingTS0, Partition, TimeStamp, S0#state{labels=Labels1}),
  