anchor.diff:                  keepalive = proplists:get_value(keepalive, Args, true),
                   wait = Wait,
                   event_client = EventClient,
  -                client = Client}}.
  +                client = Client,
  +                on_reply = OnReplyFun}}.
   
   
   handle_call(get_transport, _From, State) ->
  
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:                 replies = [],
                  terminated = false,
                  event_client,
                  client,
                  on_reply}).
  
  %%%===================================================================
  %%% API
  