sharpetronics/httpx
1
0
Fork 0
mirror of https://github.com/HoneyryderChuck/httpx.git synced 2025-08-10 00:01:27 -04:00
Code Issues Projects Releases Wiki Activity

removed @error ivar from connection

Browse Source
This commit is contained in:
HoneyryderChuck 2019-09-25 19:50:55 +01:00
parent 99a221dbc9
commit 9fd4852564
1 changed files with 7 additions and 12 deletions
Show Stats Download Patch File Download Diff File Expand all files Collapse all files

19
lib/httpx/connection.rb
View File

@ -175,9 +175,7 @@ module HTTPX
end
def send(request)
if @error
emit(:response, request, ErrorResponse.new(request, @error, @options))
elsif @parser && !@write_buffer.full?
if @parser && !@write_buffer.full?
request.headers["alt-used"] = @origin.authority if match_altsvcs?(request.uri)
parser.send(request)
else
@ -310,8 +308,6 @@ module HTTPX
def transition(nextstate)
case nextstate
when :idle
@error = nil
when :open
return if @state == :closed
@ -354,18 +350,17 @@ module HTTPX
reset
end
def handle_error(e)
if e.instance_of?(TimeoutError) && @timeout
@timeout -= e.timeout
def handle_error(error)
if error.instance_of?(TimeoutError) && @timeout
@timeout -= error.timeout
return unless @timeout <= 0
e = e.to_connection_error if connecting?
error = error.to_connection_error if connecting?
end
parser.handle_error(e) if @parser && parser.respond_to?(:handle_error)
@error = e
parser.handle_error(error) if @parser && parser.respond_to?(:handle_error)
@pending.each do |request, _|
request.emit(:response, ErrorResponse.new(request, @error, @options))
request.emit(:response, ErrorResponse.new(request, error, @options))
end
end
end