Maximum concurrent stream is defined only by the local settings.

Author: Maaarcocr

lib/protocol/http2/connection.rb

@@ -77,7 +77,7 @@ def maximum_frame_size
 			end
 
 			def maximum_concurrent_streams
-				[@local_settings.maximum_concurrent_streams, @remote_settings.maximum_concurrent_streams].min
+				@local_settings.maximum_concurrent_streams
 			end
 
 			attr :framer

spec/protocol/http2/connection_spec.rb

@@ -189,4 +189,52 @@
 			expect(frame).to be_end_stream
 		end
 	end
+
+	it "allows client to create new stream and send headers when client maximum concurrent streams is 0" do
+		client.local_settings.current.maximum_concurrent_streams = 0
+		client_stream = client.create_stream
+		request_headers = [[':method', 'GET'], [':path', '/'], [':authority', 'localhost']]
+		client_stream.send_headers(nil, request_headers)
+
+		expect(server).to receive(:receive_headers).once.and_wrap_original do |method, frame|
+			headers = method.call(frame)
+
+			expect(headers).to be == request_headers
+		end
+
+		server.read_frame
+	end
+
+	it "does not allow client to create new stream and send headers when server maximum concurrent streams is 0" do
+		server.local_settings.current.maximum_concurrent_streams = 0
+		client_stream = client.create_stream
+		request_headers = [[':method', 'GET'], [':path', '/'], [':authority', 'localhost']]
+		client_stream.send_headers(nil, request_headers)
+
+		expect { server.read_frame }.to raise_error(Protocol::HTTP2::ProtocolError)
+	end
+
+	it "allows server to create new stream and send headers when server maximum concurrent streams is 0" do
+		server.local_settings.current.maximum_concurrent_streams = 0
+		server_stream = server.create_stream
+		request_headers = [[':method', 'GET'], [':path', '/'], [':authority', 'localhost']]
+		server_stream.send_headers(nil, request_headers)
+
+		expect(client).to receive(:receive_headers).once.and_wrap_original do |method, frame|
+			headers = method.call(frame)
+
+			expect(headers).to be == request_headers
+		end
+
+		client.read_frame
+	end
+
+	it "does not allow server to create new stream send headers when client maximum concurrent streams is 0" do
+		client.local_settings.current.maximum_concurrent_streams = 0
+		server_stream = server.create_stream
+		request_headers = [[':method', 'GET'], [':path', '/'], [':authority', 'localhost']]
+		server_stream.send_headers(nil, request_headers)
+
+		expect { client.read_frame }.to raise_error(Protocol::HTTP2::ProtocolError)
+	end
 end