anchor.diff:              send_events(YawsPid, Domain, [Event])
       end,
       {noreply, State};
  +handle_info(ping, {YawsPid, _Domain, _Search, _Sid} = State) ->
  +    yaws_api:stream_chunk_deliver(YawsPid, ":\n\n"),
  +    ping(),
  +    {noreply, State};
   handle_info(Event, State) ->
       ?ERROR_MSG("unexpected ~p", [Event]),
       {noreply, State}.
  
positive.code: % Private API
  %
  
  send_events(_, _, []) ->
      ok;
  send_events(YawsPid, Domain, [#uce_event{datetime=Datetime} = Event|Events]) ->
  
negative.code:     send_events(YawsPid, Domain, PreviousEvents),
      ?PUBSUB_MODULE:subscribe(self(), Domain, Location, From, Types, Parent),
      uce_presence:add_stream(Domain, Sid),
      ping(),
      {ok, {YawsPid,
            Domain,
            Search,
  