Move count to Async::HTTP::Server.

Author: ioquatix

lib/async/http/protocol/http2/client.rb

@@ -32,8 +32,6 @@ def create_response
 					def call(request)
 						raise ::Protocol::HTTP2::Error, "Connection closed!" if self.closed?
 
-						@count += 1
-						
 						response = create_response
 						write_request(response, request)
 						read_response(response)

lib/async/http/protocol/http2/connection.rb

@@ -29,7 +29,6 @@ module Connection
 					def initialize(*)
 						super
 
-						@count = 0
 						@reader = nil
 
 						# Writing multiple frames at the same time can cause odd problems if frames are only partially written. So we use a semaphore to ensure frames are written in their entirety.
@@ -41,7 +40,7 @@ def synchronize(&block)
 					end
 
 					def to_s
-						"\#<#{self.class} #{@count} requests, #{@streams.count} active streams>"
+						"\#<#{self.class} #{@streams.count} active streams>"
 					end
 
 					def as_json(...)

lib/async/http/protocol/http2/server.rb

@@ -51,8 +51,6 @@ def each(task: Task.current)
 						@requests&.async do |task, request|
 							task.annotate("Incoming request: #{request.method} #{request.path.inspect}.")
 
-							@count += 1
-							
 							task.defer_stop do
 								response = yield(request)
 							rescue

lib/async/http/server.rb

@@ -24,6 +24,8 @@ def initialize(app, endpoint, protocol: endpoint.protocol, scheme: endpoint.sche
 				@endpoint = endpoint
 				@protocol = protocol
 				@scheme = scheme
+				
+				@count = 0
 			end
 
 			def as_json(...)
@@ -42,6 +44,14 @@ def to_json(...)
 			attr :protocol
 			attr :scheme
 
+			attr :count
+			
+			def call(...)
+				@count += 1
+				
+				super
+			end
+			
 			def accept(peer, address, task: Task.current)
 				connection = @protocol.server(peer)
 

test/async/http/protocol/http2.rb

@@ -17,7 +17,7 @@
 			response = client.get("/")
 			connection = response.connection
 
-			expect(connection.as_json).to be =~ /#<Async::HTTP::Protocol::HTTP2::Client 1 requests, \d+ active streams>/
+			expect(connection.as_json).to be =~ /#<Async::HTTP::Protocol::HTTP2::Client \d+ active streams>/
 		ensure
 			response&.close
 		end