http/1: passing retries as well (not doing anything with them doh)

This commit is contained in:
HoneyryderChuck 2018-01-06 19:25:47 +00:00
parent 951504ae98
commit c55771906d

View File

@ -12,6 +12,7 @@ module HTTPX
def initialize(buffer, options)
@options = Options.new(options)
@max_concurrent_requests = @options.max_concurrent_requests
@retries = options.max_retries
@parser = HTTP::Parser.new(self)
@parser.header_value_type = :arrays
@buffer = buffer
@ -34,7 +35,7 @@ module HTTPX
@parser << data
end
def send(request, **)
def send(request, retries: @retries, **)
if @requests.size >= @max_concurrent_requests
@pending << request
return