parser#consume: skip fully buffered requests

lib/httpx/connection/http1.rb

@@ -63,6 +63,7 @@ module HTTPX
       requests_limit = [@max_concurrent_requests, @max_requests, @requests.size].min
       @requests.each_with_index do |request, idx|
         break if idx >= requests_limit
+        next if request.state == :done
 
         handle(request)
       end

lib/httpx/connection/http2.rb

@@ -72,6 +72,8 @@ module HTTPX
 
     def consume
       @streams.each do |request, stream|
+        next if request.state == :done
+
         handle(request, stream)
       end
     end