examples/hackernews_frontpage.rb

@@ -19,18 +19,21 @@ Signal.trap("INFO") { print_status } unless ENV.key?("CI")
 
 Thread.start do
 	frontpage = HTTPX.get("https://news.ycombinator.com").to_s
-
+	
 	html = Oga.parse_html(frontpage)
-
+	
-	links = html.css('.athing .title a').map{|link| link.get('href') }.select { |link| URI(link).absolute? }
+	links = html.css('.itemlist a.storylink').map{|link| link.get('href') }
-
+	
 	links = links.select {|l| l.start_with?("https") }
-
+	
 	puts links
-
+	
 	responses = HTTPX.get(*links)
-
+	
 	links.each_with_index do |l, i|
   	puts "#{responses[i].status}: #{l}"
 	end
 end.join
+
+
+

examples/hackernews_pages.rb

@@ -1,7 +1,7 @@
 require "httpx"
 require "oga"
 
-http = HTTPX.plugin(:persistent).with(timeout: { request_timeout: 5 })
+http = HTTPX.plugin(:persistent).with(timeout: { operation_timeut: 5, connect_timeout: 5})
 
 PAGES = (ARGV.first || 10).to_i
 pages = PAGES.times.map do |page|
@@ -16,11 +16,10 @@ Array(http.get(*pages)).each_with_index.map do |response, i|
   end
   html = Oga.parse_html(response.to_s)
   # binding.irb
-  page_links = html.css('.athing .title a').map{|link| link.get('href') }.select { |link| URI(link).absolute? }
+  page_links = html.css('.itemlist a.titlelink').map{|link| link.get('href') }
   puts "page(#{i+1}): #{page_links.size}"
   if page_links.size == 0
     puts "error(#{response.status}) on page #{i+1}"
-    next
   end
   # page_links.each do |link|
   #   puts "link: #{link}"
@@ -32,11 +31,6 @@ end
 links = links.each_with_index do |pages, i|
   puts "Page: #{i+1}\t Links: #{pages.size}"
   pages.each do |page|
-    case page
+    puts "URL: #{page.uri} (#{page.status})"
-    in status:
-      puts "URL: #{page.uri} (#{status})"
-    in error:
-      puts "URL: #{page.uri} (#{error.message})"
-    end
   end
 end

examples/proxy_get.rb

@@ -6,9 +6,11 @@ include HTTPX
 URLS  = %w[http://nghttp2.org https://nghttp2.org/blog/]# * 3
 
 client = HTTPX.plugin(:proxy)
-client = client.with_proxy(uri: "http://134.209.29.120:8080")
+client = client.with_proxy(uri: "http://61.7.174.110:54132")
-responses = client.get(*URLS)
+responses = client.get(URLS)
 puts responses.map(&:status)
 
 # response = client.get(URLS.first)
 # puts response.status
+
+

lib/httpx/connection.rb

@@ -273,7 +273,7 @@ module HTTPX
     end
 
     def timeout
-      return @timeout if @timeout
+      return @timeout if defined?(@timeout)
 
       return @options.timeout[:connect_timeout] if @state == :idle
 
@@ -518,6 +518,7 @@ module HTTPX
         else
           transition(:closing)
           transition(:closed)
+          emit(:reset)
 
           @parser.reset if @parser
           transition(:idle)
@@ -616,7 +617,7 @@ module HTTPX
     def purge_after_closed
       @io.close if @io
       @read_buffer.clear
-      @timeout = nil
+      remove_instance_variable(:@timeout) if defined?(@timeout)
     end
 
     def build_socket(addrs = nil)

lib/httpx/connection/http1.rb

@@ -181,7 +181,7 @@ module HTTPX
       if response.is_a?(ErrorResponse)
         disable
       else
-        manage_connection(request, response)
+        manage_connection(response)
       end
 
       if exhausted?
@@ -224,7 +224,7 @@ module HTTPX
 
     private
 
-    def manage_connection(request, response)
+    def manage_connection(response)
       connection = response.headers["connection"]
       case connection
       when /keep-alive/i
@@ -254,7 +254,7 @@ module HTTPX
         disable
       when nil
         # In HTTP/1.1, it's keep alive by default
-        return if response.version == "1.1" && request.headers["connection"] != "close"
+        return if response.version == "1.1"
 
         disable
       end

lib/httpx/plugins/proxy/http.rb

@@ -76,6 +76,7 @@ module HTTPX
                   else
                     transition(:closing)
                     transition(:closed)
+                    emit(:reset)
 
                     parser.reset if @parser
                     transition(:idle)

lib/httpx/pool.rb

@@ -223,6 +223,9 @@ module HTTPX
         @connected_connections += 1
       end
       select_connection(connection)
+      connection.on(:close) do
+        unregister_connection(connection)
+      end
     end
 
     def unregister_connection(connection)

lib/httpx/resolver.rb

@@ -87,18 +87,16 @@ module HTTPX
     def lookup(hostname, ttl)
       return unless @lookups.key?(hostname)
 
-      entries = @lookups[hostname] = @lookups[hostname].select do |address|
+      @lookups[hostname] = @lookups[hostname].select do |address|
         address["TTL"] > ttl
       end
-
+      ips = @lookups[hostname].flat_map do |address|
-      ips = entries.flat_map do |address|
         if address.key?("alias")
           lookup(address["alias"], ttl)
         else
           IPAddr.new(address["data"])
         end
-      end.compact
+      end
-
       ips unless ips.empty?
     end
 

lib/httpx/session.rb

@@ -260,9 +260,7 @@ module HTTPX
       connection.on(:open) do
         emit(:connection_opened, connection.origin, connection.io.socket)
         # only run close callback if it opened
-      end
+        connection.on(:close) { emit(:connection_closed, connection.origin, connection.io.socket) }
-      connection.on(:close) do
-        emit(:connection_closed, connection.origin, connection.io.socket) if connection.used?
       end
       catch(:coalesced) do
         pool.init_connection(connection, options)

regression_tests/bug_1_1_1_test.rb

@@ -1,30 +0,0 @@
-# frozen_string_literal: true
-
-require "test_helper"
-require "support/http_helpers"
-
-class Bug_1_1_1_Test < Minitest::Test
-  include HTTPHelpers
-
-  def test_conection_callbacks_fire_setup_once
-    uri = build_uri("/get")
-
-    connected = 0
-
-    HTTPX.on_connection_opened { |*| connected += 1 }
-         .on_connection_closed { |*| connected -= 1 }
-         .wrap do |session|
-      3.times.each do
-        response = session.get(uri)
-        verify_status(response, 200)
-        assert connected.zero?
-      end
-    end
-  end
-
-  private
-
-  def scheme
-    "http://"
-  end
-end

sig/connection/http1.rbs

@@ -59,13 +59,13 @@ module HTTPX
 
     def initialize: (Buffer, options) -> untyped
 
-    def manage_connection: (Request request, Response response) -> void
+    def manage_connection: (Response) -> void
 
     def disable: () -> void
 
     def disable_pipelining: () -> void
 
-    def set_protocol_headers: (Request request) -> _Each[[String, String]]
+    def set_protocol_headers: (Request) -> _Each[[String, String]]
 
     def handle: (Request request) -> void
 

test/support/ci/squid/proxy.conf

@@ -22,7 +22,3 @@ acl localnet src fe80::/10      # RFC 4291 link-local (directly plugged) machine
 
 http_port 3128
 https_port 3128
-
-# limit the number of file descriptors so that Squid doesn't try allocating
-# hundreds of gigabytes of RAM on systems with large NOFILE ulimits
-max_filedescriptors 1024