lib/httpx/connection/http2.rb in httpx-0.6.0 vs lib/httpx/connection/http2.rb in httpx-0.6.1
- old
+ new
@@ -71,9 +71,12 @@
def handle_error(ex)
@streams.each_key do |request|
emit(:error, request, ex)
end
+ @pending.each do |request|
+ emit(:error, request, ex)
+ end
end
private
def send_pending