494_connection = new Http2Connection(httpConnectionContext);

36_connection.ServerSettings.MaxConcurrentStreams = 2; 195Assert.Equal(1, _connection.StreamPool.Count); 252Assert.Equal(1, _connection.StreamPool.Count); 253Assert.True(_connection.StreamPool.TryPeek(out var stream1)); 270Assert.Equal(1, _connection.StreamPool.Count); 271Assert.True(_connection.StreamPool.TryPeek(out var stream2)); 371Assert.Equal(1, _connection.StreamPool.Count); 416Assert.Equal(0, _connection.StreamPool.Count); 422var stream = _connection._streams[1]; 431Assert.Equal(1, _connection.StreamPool.Count); 447Assert.Equal(0, _connection.StreamPool.Count); 488Assert.Equal(2, _connection.StreamPool.Count); 515Assert.Equal(0, _connection.StreamPool.Count); 525var stream = _connection._streams[1]; 535Assert.Equal(1, _connection.StreamPool.Count); 536Assert.True(_connection.StreamPool.TryPeek(out var pooledStream)); 554Assert.Equal(0, _connection.StreamPool.Count); 564Assert.Equal(1, _connection.StreamPool.Count); 565Assert.True(_connection.StreamPool.TryPeek(out pooledStream)); 600var stream = _connection._streams[1]; 613Assert.Equal(0, _connection.StreamPool.Count); 633_connection.ServerSettings.MaxConcurrentStreams = 1; 645Assert.Equal(0, _connection.StreamPool.Count); 658_connection.ServerSettings.MaxConcurrentStreams = 1; 675Assert.Equal(0, _connection.StreamPool.Count); 689Assert.Equal(0, _connection.StreamPool.Count); 704Assert.Equal(1, _connection.StreamPool.Count); 706_connection.StreamPool.TryPeek(out var pooledStream); 711Assert.Equal(1, _connection.StreamPool.Count); 716Assert.Equal(0, _connection.StreamPool.Count); 1687Assert.Equal((uint)100, _connection.MaxTrackedStreams); 1700Assert.Equal((uint)200, _connection.MaxTrackedStreams); 1713Assert.Equal((uint)int.MaxValue * 2, _connection.MaxTrackedStreams); 1725Assert.Equal(100u, _connection.MaxTrackedStreams); 1726_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 1751_connection.SendEnhanceYourCalmOnStartStream = true; 2052_connection.HandleReadDataRateTimeout(); 2511_connection.ServerSettings.MaxConcurrentStreams = 1; 3643_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 3695_connection.ServerSettings.HeaderTableSize = 0; 3696_connection.ServerSettings.MaxConcurrentStreams = 1; 3697_connection.ServerSettings.MaxHeaderListSize = 4 * 1024; 3698_connection.ServerSettings.InitialWindowSize = 1024 * 1024 * 10; 3700_connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 3903_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MaxAllowedMaxFrameSize; 3964_connection.ServerSettings.MaxFrameSize = Http2PeerSettings.MinAllowedMaxFrameSize + 1024; 4174var lifetime = _connection.ConnectionFeatures.Get<IConnectionLifetimeNotificationFeature>(); 5137_connection.OnInputOrOutputCompleted(); 5152_connection.Abort(new ConnectionAbortedException(), ConnectionEndReason.AbortedByApp); 5227_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5260_connection.StopProcessingNextRequest(ConnectionEndReason.AppShutdownTimeout); 5312_connection.OnInputOrOutputCompleted(); 5332await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5352await _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)).DefaultTimeout(); 5519_connection.ServerSettings.MaxConcurrentStreams = 0; // Refuse all streams 5521var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_noopApplication)); 5601_connection.ServerSettings.MaxConcurrentStreams = 1; 5603var connectionTask = _connection.ProcessRequestsAsync(new DummyApplication(_ => requestBlock.Task)); 5674_connection.ServerSettings.MaxConcurrentStreams = 1; 5885await SendAsync(Encoding.ASCII.GetBytes($"GET /{new string('a', _connection.Limits.MaxRequestLineSize)} HTTP/1.1\r\n")); 5902_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));