494_connection = new Http2Connection(httpConnectionContext);

36_connection.ServerSettings.MaxConcurrentStreams = 2; 196Assert.Equal(1, _connection.StreamPool.Count); 253Assert.Equal(1, _connection.StreamPool.Count); 254Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 271Assert.Equal(1, _connection.StreamPool.Count); 272Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 372Assert.Equal(1, _connection.StreamPool.Count); 417Assert.Equal(0, _connection.StreamPool.Count); 423var stream = _connection._streams[1]; 432Assert.Equal(1, _connection.StreamPool.Count); 448Assert.Equal(0, _connection.StreamPool.Count); 489Assert.Equal(2, _connection.StreamPool.Count); 516Assert.Equal(0, _connection.StreamPool.Count); 526var stream = _connection._streams[1]; 536Assert.Equal(1, _connection.StreamPool.Count); 537Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 555Assert.Equal(0, _connection.StreamPool.Count); 565Assert.Equal(1, _connection.StreamPool.Count); 566Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 601var stream = _connection._streams[1]; 614Assert.Equal(0, _connection.StreamPool.Count); 634_connection.ServerSettings.MaxConcurrentStreams = 1; 646Assert.Equal(0, _connection.StreamPool.Count); 659_connection.ServerSettings.MaxConcurrentStreams = 1; 676Assert.Equal(0, _connection.StreamPool.Count); 690Assert.Equal(0, _connection.StreamPool.Count); 705Assert.Equal(1, _connection.StreamPool.Count); 707_connection.StreamPool.TryPeek(out var pooledStream); 712Assert.Equal(1, _connection.StreamPool.Count); 717Assert.Equal(0, _connection.StreamPool.Count); 1688Assert.Equal((uint)100, _connection.MaxTrackedStreams); 1701Assert.Equal((uint)200, _connection.MaxTrackedStreams); 1714Assert.Equal((uint)int.MaxValue * 2, _connection.MaxTrackedStreams); 1726Assert.Equal(100u, _connection.MaxTrackedStreams); 1727_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 1752_connection.SendEnhanceYourCalmOnStartStream = true; 2052_connection.HandleReadDataRateTimeout(); 2581_connection.ServerSettings.MaxConcurrentStreams = 1; 3774_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 3826_connection.ServerSettings.HeaderTableSize = 0; 3827_connection.ServerSettings.MaxConcurrentStreams = 1; 3828_connection.ServerSettings.MaxHeaderListSize = 4 * 1024; 3829_connection.ServerSettings.InitialWindowSize = 1024 * 1024 * 10; 3831_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 4034_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MaxAllowedMaxFrameSize; 4095_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MinAllowedMaxFrameSize + 1024; 4305var lifetime = _connection.ConnectionFeatures.Get<IConnectionLifetimeNotificationFeature>(); 5268_connection.OnInputOrOutputCompleted(); 5283_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 5358_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5391_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5443_connection.OnInputOrOutputCompleted(); 5463await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5483await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5650_connection.ServerSettings.MaxConcurrentStreams = 0; // Refuse all streams 5652var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 5732_connection.ServerSettings.MaxConcurrentStreams = 1; 5734var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_ => requestBlock.Task)); 5805_connection.ServerSettings.MaxConcurrentStreams = 1; 6016await SendAsync(Encoding.ASCII.GetBytes($"GET /{new string('a', _connection.Limits.MaxRequestLineSize)} HTTP/1.1\r\n")); 6033_connection.ConnectionFeatures.Set<ITlsHandshakeFeature>(tlsHandshakeMock.Object);

18Assert.Null(_connection._keepAlive); 48Assert.Equal(KeepAliveState.PingSent, _connection._keepAlive._state); 202Assert.Equal(KeepAliveState.Timeout, _connection._keepAlive._state); 223Assert.Equal(KeepAliveState.PingSent, _connection._keepAlive._state); 230Assert.Equal(KeepAliveState.None, _connection._keepAlive._state);

495_connection._streamLifetimeHandler = new LifetimeHandlerInterceptor(_connection._streamLifetimeHandler, this); 498httpConnection.Initialize(_connection); 546if (_connection == null) 555var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(application)); 608_ => throw new NotImplementedException($"{nameof(_connection.ProcessRequestsAsync)} should invoked instead - hence transport connection manager does not have the connection registered."), 1389((IRequestProcessor)_connection)?.Tick(timestamp);

23_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication));

182var originalHandler = _connection._streamLifetimeHandler; 193_connection._streamLifetimeHandler = streamLifetimeHandler.Object; 249Assert.Equal(1, _connection.StreamPool.Count); 250Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 621var originalHandler = _connection._streamLifetimeHandler; 635_connection._streamLifetimeHandler = streamLifetimeHandler.Object; 686Assert.Equal(1, _connection.StreamPool.Count); 687Assert.True(_connection.StreamPool.TryPeek(out var pooledStream));