class Async::HTTP::Client

def request(*args, &block)
	@connections.acquire do |connection|
		response = connection.send_request(@authority, *args)
		
		begin
			yield response if block_given?
		ensure
			# This forces the stream to complete reading.
			response.finish
		end
		
		return response
	end
end