class Async::HTTP::Client

def make_pool(connection_limit = nil)
	Pool.new(connection_limit) do
		Async.logger.debug(self) {"Making connection to #{@endpoint.inspect}"}
		
		peer = @endpoint.connect
		
		@protocol.client(IO::Stream.new(peer))
	end
end