anchor.diff:           pause/2,
            get_active/1,
            set_active/2,
  -         recv/1]).
  +         recv/1,
  +         get_requests/1]).
   
   -define(WAIT_FOR_SOCKET_CLOSE_TIMEOUT, 200).
   -define(SERVER, ?MODULE).
  
positive.code: %%% Helpers
  %%%===================================================================
  send(#transport{socket = {Host, Port, Path}} = Transport, Body,
       #state{requests = Requests} = State) ->
      Headers = [{"Content-Type", "text/xml; charset=utf-8"}],
      Self = self(),
      AsyncReq = fun() ->
          {ok, Reply} =
              lhttpc:request(Host, Port, false, Path, 'POST',
                  Headers, exml:to_iolist(Body), infinity, []),
          Self ! {http_reply, Reply, Transport}
      end,
      proc_lib:spawn_link(AsyncReq),
      State#state{rid = State#state.rid+1,
                  requests = Requests + 1}.
  
  send0(Transport, Elem, State) ->
      send(Transport, wrap_elem(Elem, State), State).
  
negative.code: 
  
  %% Handle async HTTP request replies.
  handle_info({http_reply, Ref, {_StatusAndReason, _Hdrs, Body},
               Transport}, S) ->
      NewRequests = lists:keydelete(Ref, 1, S#state.requests),
      NS = handle_data(Body, S#state{requests = NewRequests}),
      NNS = case {NS#state.keepalive, NS#state.requests == []} of
          {false, _} ->
              NS;
          {true, true} ->
  