anchor.diff:                  replies = [],
                   terminated = false,
                   event_client,
  -                client}).
  +                client,
  +                on_reply}).
   
   %%%===================================================================
   %%% API
  
positive.code: send(Transport, Body, State) ->
      send(Transport, Body, State#state.rid+1, State).
  
  send(Transport, Body, NewRid, #state{requests = Requests} = S) ->
      Ref = make_ref(),
      Self = self(),
      AsyncReq = fun() ->
              {ok, Reply} = request(Transport, Body),
              Self ! {http_reply, Ref, Reply, Transport}
      end,
      NewRequests = [{Ref, proc_lib:spawn_link(AsyncReq)} | Requests],
      S#state{rid = NewRid, requests = NewRequests}.
  
  sync_send(Transport, Body, S=#state{}) ->
      {ok, Reply} = request(Transport, Body),
      {ok, Reply, S#state{rid = S#state.rid+1}}.
  
  send0(Transport, Elem, State) ->
  
negative.code:     {noreply, NNS};
  handle_info(_, State) ->
      {noreply, State}.
  
  
  terminate(_Reason, #state{client = Client, parser = Parser}) ->
      fusco:disconnect(Client),
      exml_stream:free_parser(Parser).
  
  
  code_change(_OldVsn, State, _Extra) ->
      {ok, State}.
  