anchor.diff:                 compress = false,
                  rcv_pid = self()}.
   
  -wrap_elem(#xmlstreamstart{attrs=Attrs}) ->
  +wrap_elem(#xmlstreamstart{attrs=Attrs}, _) ->
       Version = proplists:get_value(<<"version">>, Attrs, <<"1.0">>),
       Lang = proplists:get_value(<<"xml:lang">>, Attrs, <<"en">>),
       To = proplists:get_value(<<"to">>, Attrs, <<"localhost">>),
  
positive.code:     send(Socket, exml:to_iolist(StreamEnd)),
      {stop, normal, ok, State}.
  
  handle_cast(reset_parser, #state{parser = Parser} = State) ->
      {ok, NewParser} = exml_stream:reset_parser(Parser),
      {noreply, State#state{parser = NewParser}}.
  
  handle_info({tcp, Socket, Data}, State) ->
      handle_data(Socket, Data, State);
  handle_info(_, State) ->
      {noreply, State}.
  
  
negative.code: -define(WAIT_FOR_SOCKET_CLOSE_TIMEOUT, 200).
  -define(SERVER, ?MODULE).
  
  -record(state, {owner, url, parser, sid = nil}).
  
  %%%===================================================================
  %%% API
  