request: do not buffer requests if buffer is full

This commit is contained in:
HoneyryderChuck 2017-12-12 02:21:35 +00:00
parent fd25548ffd
commit e779eaa8ba

View File

@ -79,7 +79,7 @@ module HTTPX
end end
def send(request, **args) def send(request, **args)
if @parser if @parser && !@write_buffer.full?
parser.send(request, **args) parser.send(request, **args)
else else
@pending << [request, args] @pending << [request, args]
@ -122,6 +122,7 @@ module HTTPX
return if @io.closed? return if @io.closed?
while (request, args = @pending.shift) while (request, args = @pending.shift)
parser.send(request, **args) parser.send(request, **args)
break if @write_buffer.full?
end end
end end