fixing usage of active_stream_count, which changed in http-2-next, and never decrements; using local active stream count instead

This commit is contained in:
HoneyryderChuck 2019-11-30 14:59:18 +00:00
parent ab67491a55
commit e30469f8a3

View File

@ -41,7 +41,7 @@ module HTTPX
def send(request, **)
if !@handshake_completed ||
@connection.active_stream_count >= @max_concurrent_requests
@streams.size >= @max_concurrent_requests
@pending << request
return
end
@ -224,7 +224,7 @@ module HTTPX
emit(:error, request, ex)
end
end
return unless @connection.state == :closed && @connection.active_stream_count.zero?
return unless @connection.state == :closed && @streams.size.zero?
emit(:close)
end