lib/async/http/protocol/http2/client.rb in async-http-0.37.9 vs lib/async/http/protocol/http2/client.rb in async-http-0.37.10
- old
+ new
@@ -36,9 +36,17 @@
framer = ::HTTP::Protocol::HTTP2::Framer.new(@stream)
super(framer)
end
+ def stop_connection(error)
+ super
+
+ @streams.each do |id, stream|
+ stream.stop_connection(error)
+ end
+ end
+
# Used by the client to send requests to the remote server.
def call(request)
@count += 1
response = Response.new(self, next_stream_id)