anchor.diff:      lhttpc:request(Host, Port, false, Path, 'POST',
                      Headers, exml:to_iolist(Body),
                      infinity, []).
  +
  +close_requests(#state{requests=Reqs} = S) ->
  +    [exit(Pid, normal) || {_Ref, Pid} <- Reqs],
  +    S#state{requests=[]}.
   
   send(Transport, Body, State) ->
       send(Transport, Body, State#state.rid+1, State).
  
positive.code: set_keepalive(#transport{rcv_pid = Pid}, NewKeepalive) ->
      gen_server:call(Pid, {set_keepalive, NewKeepalive}).
  
  pause(#transport{rcv_pid = Pid} = Transport, Seconds) ->
      gen_server:cast(Pid, {pause, Transport, Seconds}).
  
  
negative.code:     {reply, {ok, Keepalive, NewKeepalive},
       State#state{keepalive = NewKeepalive}};
  
  handle_call(mark_as_terminated, _From, #state{} = State) ->
      {reply, {ok, marked_as_terminated}, State#state{terminated=true}};
  
  handle_call(get_active, _From, #state{active = Active} = State) ->
      {reply, Active, State};
  handle_call({set_active, Active}, _From, State) ->
  