Method: HTTPX::Connection::HTTP1#consume

Defined in:
lib/httpx/connection/http1.rb

#consume ⇒ Object 



86
87
88
89
90
91
92
93
94
95
 
# File 'lib/httpx/connection/http1.rb', line 86

def consume
  requests_limit = [@max_requests, @requests.size].min
  concurrent_requests_limit = [@max_concurrent_requests, requests_limit].min
  @requests.each_with_index do |request, idx|
    break if idx >= concurrent_requests_limit
    next unless request.can_buffer?

    handle(request)
  end
end